Updated Branches: refs/heads/master 5cd83a563 -> bd69f8aa1
Fix for Spring redis v 1.0.3.RELEASE Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bd69f8aa Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bd69f8aa Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bd69f8aa Branch: refs/heads/master Commit: bd69f8aa1bfbcb350fb460b651326b1f429aecf4 Parents: 5cd83a5 Author: bibryam <bibr...@apache.org> Authored: Wed May 15 14:22:44 2013 +0100 Committer: bibryam <bibr...@apache.org> Committed: Wed May 15 14:26:06 2013 +0100 ---------------------------------------------------------------------- .../camel/component/redis/RedisConfiguration.java | 1 + .../redis/RedisConsumerIntegrationTest.java | 3 +++ 2 files changed, 4 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/bd69f8aa/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java index 6e9bb12..889dc71 100755 --- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java +++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java @@ -126,6 +126,7 @@ public class RedisConfiguration { managedListenerContainer = true; listenerContainer.setConnectionFactory(getConnectionFactory()); listenerContainer.afterPropertiesSet(); + listenerContainer.start(); return listenerContainer; } http://git-wip-us.apache.org/repos/asf/camel/blob/bd69f8aa/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/RedisConsumerIntegrationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/RedisConsumerIntegrationTest.java b/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/RedisConsumerIntegrationTest.java index 73613ac..22df19a 100755 --- a/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/RedisConsumerIntegrationTest.java +++ b/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/RedisConsumerIntegrationTest.java @@ -54,9 +54,12 @@ public class RedisConsumerIntegrationTest extends RedisTestSupport { return new RouteBuilder() { public void configure() { from("spring-redis://localhost:6379?command=SUBSCRIBE&channels=one,two&listenerContainer=#listenerContainer&redisTemplate=#redisTemplate") + .startupOrder(1) .to("mock:result"); from("direct:start") + .startupOrder(2) + .delay(2000) .to("spring-redis://localhost:6379?redisTemplate=#redisTemplate"); } };
