From 18f9fcbb5917d437a81ba1269c5d513824751282 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 2 May 2017 17:19:21 -0400 Subject: [PATCH] INT-4259: ACorrelationMH: WARN group reschedule JIRA: https://jira.spring.io/browse/INT-4259 Since DEBUG can switched off for the application, it becomes difficult to determine the wrong configuration for the discard flow from the scheduler thread. * Change logging level to the `WARN` and log the full stack-trace as well to give more information about the reason of rescheduling group for `forceComplete` **Cherry-pick to 4.3.x** --- .../aggregator/AbstractCorrelatingMessageHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java index 9ae374f9ad..27a33b0e52 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java @@ -519,9 +519,9 @@ public abstract class AbstractCorrelatingMessageHandler extends AbstractMessageP processForceRelease(groupId); } catch (MessageDeliveryException e) { - if (AbstractCorrelatingMessageHandler.this.logger.isDebugEnabled()) { - AbstractCorrelatingMessageHandler.this.logger.debug("The MessageGroup [ " - + groupId + "] is rescheduled by the reason: " + e.getMessage()); + if (AbstractCorrelatingMessageHandler.this.logger.isWarnEnabled()) { + AbstractCorrelatingMessageHandler.this.logger.warn("The MessageGroup [" + + groupId + "] is rescheduled by the reason of:", e); } scheduleGroupToForceComplete(groupId); } @@ -825,7 +825,7 @@ public abstract class AbstractCorrelatingMessageHandler extends AbstractMessageP } return messageSequenceSize.equals(getSequenceSize()) && !(this.sourceGroup != null ? this.sourceGroup.containsSequence(messageSequenceNumber) - : containsSequenceNumber(this.getMessages(), messageSequenceNumber)); + : containsSequenceNumber(this.getMessages(), messageSequenceNumber)); } return true; }