Updated Branches: refs/heads/master 7535b96c6 -> d147e5f13
CAMEL-6617 fixed the build error of RabbitMQEndpointTest Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d147e5f1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d147e5f1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d147e5f1 Branch: refs/heads/master Commit: d147e5f1301b1944403854ef4f73d39571b89d41 Parents: 7535b96 Author: Willem Jiang <ningji...@apache.org> Authored: Thu Aug 8 15:31:29 2013 +0800 Committer: Willem Jiang <ningji...@apache.org> Committed: Thu Aug 8 15:31:29 2013 +0800 ---------------------------------------------------------------------- .../apache/camel/component/rabbitmq/RabbitMQEndpointTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d147e5f1/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 f66ab85..df29279 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 @@ -41,10 +41,12 @@ public class RabbitMQEndpointTest extends CamelTestSupport { Mockito.when(envelope.getExchange()).thenReturn(exchangeName); Mockito.when(envelope.getDeliveryTag()).thenReturn(tag); - Exchange exchange = endpoint.createRabbitExchange(envelope); + byte[] body = new byte[20]; + Exchange exchange = endpoint.createRabbitExchange(envelope, body); assertEquals(exchangeName, exchange.getIn().getHeader(RabbitMQConstants.EXCHANGE_NAME)); assertEquals(routingKey, exchange.getIn().getHeader(RabbitMQConstants.ROUTING_KEY)); assertEquals(tag, exchange.getIn().getHeader(RabbitMQConstants.DELIVERY_TAG)); + assertEquals(body, exchange.getIn().getBody()); } @Test
