slow_consumer update

th2-net · Oct 4, 2023 · fe4c51b · fe4c51b
1 parent d4b64e5
commit fe4c51b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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) {