improve lifecycle of RedisMessageListenerContainer

Costin Leau · Costin Leau · commit 902104e458c6 · 2012-03-29T17:47:38.000+03:00
DATAREDIS-81
diff --git a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java
@@ -122,8 +122,6 @@ public void afterPropertiesSet() {
 		}
 
 		initialized = true;
-
-		start();
 	}
 
 	/**
diff --git a/src/test/java/org/springframework/data/redis/listener/PubSubTests.java b/src/test/java/org/springframework/data/redis/listener/PubSubTests.java
@@ -72,6 +72,7 @@ public void setUp() throws Exception {
 		container.setBeanName("container");
 		container.addMessageListener(adapter, Arrays.asList(new ChannelTopic(CHANNEL)));
 		container.afterPropertiesSet();
+		container.start();
 
 		Thread.sleep(1000);
 	}

Original file line number	Diff line number	Diff line change
`@@ -122,8 +122,6 @@ public void afterPropertiesSet() {`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`initialized = true;`
`125`		`-`
`126`		`- start();`
`127`	`125`	`}`
`128`	`126`
`129`	`127`	`/**`
Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,7 @@ public void setUp() throws Exception {`
`72`	`72`	`container.setBeanName("container");`
`73`	`73`	`container.addMessageListener(adapter, Arrays.asList(new ChannelTopic(CHANNEL)));`
`74`	`74`	`container.afterPropertiesSet();`
	`75`	`+ container.start();`
`75`	`76`
`76`	`77`	`Thread.sleep(1000);`
`77`	`78`	`}`