camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject [2/2] git commit: CAMEL-7009 Added an integration test to verify the ReplyTo header setting
Date Tue, 26 Nov 2013 08:51:41 GMT
CAMEL-7009 Added an integration test to verify the ReplyTo header setting


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e8c7f0e1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e8c7f0e1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e8c7f0e1

Branch: refs/heads/camel-2.12.x
Commit: e8c7f0e1e2e53ae64e9b03b8051b485bc0e465bd
Parents: a993a0e
Author: Willem Jiang <willem.jiang@gmail.com>
Authored: Tue Nov 26 16:24:15 2013 +0800
Committer: Willem Jiang <willem.jiang@gmail.com>
Committed: Tue Nov 26 16:50:49 2013 +0800

----------------------------------------------------------------------
 .../apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java   | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/e8c7f0e1/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java
----------------------------------------------------------------------
diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java
index 0c57391..da7b27a 100644
--- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java
+++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerIntTest.java
@@ -55,6 +55,7 @@ public class RabbitMQConsumerIntTest extends CamelTestSupport {
     public void sentMessageIsReceived() throws InterruptedException, IOException {
 
         to.expectedMessageCount(1);
+        to.expectedHeaderReceived(RabbitMQConstants.REPLY_TO, "myReply");
 
         ConnectionFactory factory = new ConnectionFactory();
         factory.setHost("localhost");
@@ -65,6 +66,7 @@ public class RabbitMQConsumerIntTest extends CamelTestSupport {
         Connection conn = factory.newConnection();
 
         AMQP.BasicProperties.Builder properties = new AMQP.BasicProperties.Builder();
+        properties.replyTo("myReply");
 
         Channel channel = conn.createChannel();
         channel.basicPublish(EXCHANGE, "", properties.build(), "hello world".getBytes());


Mime
View raw message