Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1903 polishing, renamed to setIdGenerator(..) method

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-05-14 14:11:38 -04:00
parent 7613464ee0
commit 783b941a8e
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-core/src/main/java/org/springframework/integration/MessageHeaders.java
View File

@@ -106,13 +106,13 @@ public final class MessageHeaders implements Map<String, Object>, 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(){

2
spring-integration-core/src/main/java/org/springframework/integration/config/IdGeneratorConfigurer.java
View File

@@ -53,7 +53,7 @@ public class IdGeneratorConfigurer implements ApplicationListener<ContextRefresh
if (logger.isDebugEnabled()) {
logger.debug("Using MessageHeaders.IdGenerator [" + idGenerationStrategy + "]");
}
MessageHeaders.setMessageIdGenerationStrategy(idGenerationStrategy);
MessageHeaders.setIdGenerator(idGenerationStrategy);
}
catch (NoSuchBeanDefinitionException ex) {
// We need to use the default.

2
spring-integration-core/src/test/java/org/springframework/integration/core/MessageIdGenerationTests.java
View File

@@ -62,7 +62,7 @@ public class MessageIdGenerationTests {
watch.stop();
double defaultGeneratorElapsedTime = watch.getTotalTimeSeconds();
MessageHeaders.setMessageIdGenerationStrategy(new IdGenerator() {
MessageHeaders.setIdGenerator(new IdGenerator() {
public UUID generateId() {
return TimeBasedUUIDGenerator.generateId();
}