diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java index 4b37968..b36581e 100644 --- a/src/main/java/com/exactpro/th2/FixHandler.java +++ b/src/main/java/com/exactpro/th2/FixHandler.java @@ -1491,6 +1491,7 @@ private void setupSlowConsumerStrategy(RuleConfiguration configuration) { } private void cleanupSlowConsumerStrategy() { + strategy.updateReceiveMessageStrategy(x -> {x.setReceivePreprocessor(this::defaultMessageProcessor); return Unit.INSTANCE;}); try { Thread.sleep(strategy.getState().getConfig().getCleanUpDuration().toMillis()); } catch (Exception e) {