From fe4c51b446bffaa77d48c41387eaadabd28adad2 Mon Sep 17 00:00:00 2001
From: Denis Plotnikov <denis.plotnikov@exactprosystems.com>
Date: Wed, 4 Oct 2023 17:18:22 +0400
Subject: [PATCH] slow_consumer update

---
 src/main/java/com/exactpro/th2/FixHandler.java | 1 +
 1 file changed, 1 insertion(+)

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) {