You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bi...@apache.org on 2013/05/15 15:33:18 UTC
git commit: Fix for Spring redis v 1.0.3.RELEASE
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 <bi...@apache.org>
Authored: Wed May 15 14:22:44 2013 +0100
Committer: bibryam <bi...@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");
}
};