diff --git a/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java b/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java index 8b2a2e4520..db06edc676 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java @@ -112,7 +112,7 @@ public abstract class AbstractMessageGroupStore extends AbstractBatchingMessageG this.expiryCallbacks.stream() .anyMatch(UniqueExpiryCallback.class::isInstance); - if (!uniqueExpiryCallbackPresent && this.logger.isErrorEnabled()) { + if (uniqueExpiryCallbackPresent && this.logger.isErrorEnabled()) { this.logger.error("Only one instance of 'UniqueExpiryCallback' can be registered in the " + "'MessageGroupStore'. Use a separate 'MessageGroupStore' for each aggregator/resequencer."); } diff --git a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandlerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandlerTests.java index c3c4501977..48ccab2acd 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandlerTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandlerTests.java @@ -349,6 +349,8 @@ public class AbstractCorrelatingMessageHandlerTests { } }; handler.setMessageStore(messageStore); + // test UniqueExpiryCallback error message + // new AggregatingMessageHandler(new DefaultAggregatingMessageGroupProcessor()).setMessageStore(messageStore); handler.handleMessage(MessageBuilder.withPayload("foo") .setCorrelationId(1) .setSequenceNumber(1)