diff --git a/spring-integration-core/src/main/java/org/springframework/integration/MessageHeaders.java b/spring-integration-core/src/main/java/org/springframework/integration/MessageHeaders.java index 96c40dd8f5..1f592d9bb4 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/MessageHeaders.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/MessageHeaders.java @@ -106,13 +106,13 @@ public final class MessageHeaders implements Map, Serializable { } - public static void setMessageIdGenerationStrategy(IdGenerator messageIdGenerationStrategy) { + public static void setIdGenerator(IdGenerator messageIdGenerator) { Assert.state(MessageHeaders.messageIdGenerator instanceof DefaultIdGenerator, "'MessageHeaders.messageIdGenerator' " + "has already been set and can not be set again, unless reset() method is called"); if (logger.isInfoEnabled()){ - logger.info("Message IDs will be generated using custom ID generation strategy: " + messageIdGenerationStrategy); + logger.info("Message IDs will be generated using custom ID generation strategy: " + messageIdGenerator); } - MessageHeaders.messageIdGenerator = messageIdGenerationStrategy; + MessageHeaders.messageIdGenerator = messageIdGenerator; } public static void resetIdGenerator(){ diff --git a/spring-integration-core/src/main/java/org/springframework/integration/config/IdGeneratorConfigurer.java b/spring-integration-core/src/main/java/org/springframework/integration/config/IdGeneratorConfigurer.java index 2c17894e4c..b5a65749f3 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/config/IdGeneratorConfigurer.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/config/IdGeneratorConfigurer.java @@ -53,7 +53,7 @@ public class IdGeneratorConfigurer implements ApplicationListener