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 8e1fc735d9..a1140873f0 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
@@ -454,9 +454,9 @@ public abstract class AbstractCorrelatingMessageHandler extends AbstractMessageP
 									processForceRelease(groupId);
 								}
 								catch (MessageDeliveryException e) {
-									if (logger.isDebugEnabled()) {
-										logger.debug("The MessageGroup [ " + groupId +
-												"] is rescheduled by the reason: " + e.getMessage());
+									if (logger.isWarnEnabled()) {
+										logger.warn("The MessageGroup [ " + groupId +
+												"] is rescheduled by the reason of:", e);
 									}
 									scheduleGroupToForceComplete(groupId);
 								}
@@ -731,7 +731,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;
 		}