[camel-amqp] Added extra tests.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/160f02d3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/160f02d3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/160f02d3 Branch: refs/heads/camel-2.16.x Commit: 160f02d315b7792c3ec4afd86fa1029594a8c254 Parents: 940077a Author: Henryk Konsek <hekon...@gmail.com> Authored: Thu Dec 3 12:57:57 2015 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Mon Feb 29 09:29:28 2016 +0100 ---------------------------------------------------------------------- .../camel/component/amqp/AMQPRouteTest.java | 22 ++++++++++++++++++++ 1 file changed, 22 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/160f02d3/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java index ce89bc6..3ed0935 100644 --- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java +++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java @@ -20,6 +20,7 @@ import org.apache.activemq.broker.BrokerService; import org.apache.camel.CamelContext; import org.apache.camel.EndpointInject; import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.component.jms.JmsConstants; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.test.AvailablePortFinder; import org.apache.camel.test.junit4.CamelTestSupport; @@ -75,6 +76,23 @@ public class AMQPRouteTest extends CamelTestSupport { resultEndpoint.assertIsSatisfied(); } + @Test + public void testPrefixWildcard() throws Exception { + resultEndpoint.expectedMessageCount(1); + template.sendBody("amqp:wildcard.foo.bar", expectedBody); + resultEndpoint.assertIsSatisfied(); + } + + @Test + public void testIncludeDestination() throws Exception { + resultEndpoint.expectedMessageCount(1); + resultEndpoint.message(0).header("JMSDestination").isEqualTo("ping"); + template.sendBody("amqp:queue:ping", expectedBody); + resultEndpoint.assertIsSatisfied(); + } + + // Routes fixtures + protected CamelContext createCamelContext() throws Exception { CamelContext camelContext = super.createCamelContext(); camelContext.addComponent("amqp", amqpComponent("amqp://localhost:" + amqpPort)); @@ -98,6 +116,10 @@ public class AMQPRouteTest extends CamelTestSupport { from("amqp:topic:ping") .to("log:routing") .to("mock:result"); + + from("amqp:queue:wildcard.>") + .to("log:routing") + .to("mock:result"); } }; }
