You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/04/30 08:48:22 UTC
camel git commit: CAMEL-8270 Added an unit test for it
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 <wi...@gmail.com>
Authored: Thu Apr 30 14:48:21 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
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 {