Repository: camel Updated Branches: refs/heads/master d66797ba8 -> df829df9b
CAMEL-8270 Added an unit test for it Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/df829df9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/df829df9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/df829df9 Branch: refs/heads/master Commit: df829df9b04613e28c15bb13a941e8f0a3c33ee2 Parents: d66797b Author: Willem Jiang <[email protected]> Authored: Thu Apr 30 14:48:21 2015 +0800 Committer: Willem Jiang <[email protected]> Committed: Thu Apr 30 14:48:21 2015 +0800 ---------------------------------------------------------------------- .../camel/component/rabbitmq/RabbitMQEndpointTest.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/df829df9/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java index df12e65..52e76c8 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java @@ -73,6 +73,18 @@ public class RabbitMQEndpointTest extends CamelTestSupport { assertEquals(tag, exchange.getIn().getHeader(RabbitMQConstants.DELIVERY_TAG)); assertEquals(body, exchange.getIn().getBody()); } + + @Test + public void testExchangeNameIsOptional() throws Exception { + RabbitMQEndpoint endpoint1 = context.getEndpoint("rabbitmq:localhost/", RabbitMQEndpoint.class); + assertEquals("Get a wrong exchange name", "", endpoint1.getExchangeName()); + + RabbitMQEndpoint endpoint2 = context.getEndpoint("rabbitmq:localhost?autoAck=false", RabbitMQEndpoint.class); + assertEquals("Get a wrong exchange name", "", endpoint2.getExchangeName()); + + RabbitMQEndpoint endpoint3 = context.getEndpoint("rabbitmq:localhost/exchange", RabbitMQEndpoint.class); + assertEquals("Get a wrong exchange name", "exchange", endpoint3.getExchangeName()); + } @Test public void testCreatingRabbitExchangeSetsCustomHeaders() throws Exception {
