Repository: camel Updated Branches: refs/heads/master e069d74fc -> b3afcac20
CAMEL-8491: Camel POJO producer/consumer should defer starting until CamelContext is starting Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ee04384f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ee04384f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ee04384f Branch: refs/heads/master Commit: ee04384fea31a23a8e50220530e546983f26fc82 Parents: e069d74 Author: Claus Ibsen <[email protected]> Authored: Wed Mar 18 08:29:58 2015 +0100 Committer: Claus Ibsen <[email protected]> Committed: Wed Mar 18 08:29:58 2015 +0100 ---------------------------------------------------------------------- .../apache/camel/component/jms/JmsRequestReplyManualReplyTest.java | 2 ++ .../component/jms/JmsRequestReplyManualWithJMSReplyToTest.java | 2 ++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ee04384f/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java index fa7127b..e61c343 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java @@ -66,6 +66,8 @@ public class JmsRequestReplyManualReplyTest extends CamelTestSupport { @Test public void testManualRequestReply() throws Exception { + context.start(); + // send using pure JMS API to set a custom JMSReplyTo jms.send(new ActiveMQQueue("foo"), new MessageCreator() { public Message createMessage(Session session) throws JMSException { http://git-wip-us.apache.org/repos/asf/camel/blob/ee04384f/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java index de54d7f..e69487c 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java @@ -50,6 +50,8 @@ public class JmsRequestReplyManualWithJMSReplyToTest extends CamelTestSupport { @Test public void testManualRequestReply() throws Exception { + context.start(); + // send an InOnly but force Camel to pass JMSReplyTo template.send("activemq:queue:foo?preserveMessageQos=true", new Processor() { public void process(Exchange exchange) throws Exception {
