From 902104e458c656f0b48afeb547c22b8c53722b7c Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 29 Mar 2012 17:47:38 +0300 Subject: [PATCH] improve lifecycle of RedisMessageListenerContainer DATAREDIS-81 --- .../data/redis/listener/RedisMessageListenerContainer.java | 2 -- .../org/springframework/data/redis/listener/PubSubTests.java | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java index a9a8cd7ea..75c314f74 100644 --- 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 class RedisMessageListenerContainer implements InitializingBean, Disposab } 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 index 68b50ed5a..5e6524c55 100644 --- 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 class PubSubTests { container.setBeanName("container"); container.addMessageListener(adapter, Arrays.asList(new ChannelTopic(CHANNEL))); container.afterPropertiesSet(); + container.start(); Thread.sleep(1000); }