[camel] 01/01: CAMEL-12014: Added support for redelivered tag for RabbitMQ

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit e443d04aba27084d467fad2dde7e839141ccd4e9
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Nov 21 07:44:26 2017 +0100

    CAMEL-12014: Added support for redelivered tag for RabbitMQ
---
 .../org/apache/camel/component/rabbitmq/RabbitMQMessageConverter.java   | 2 +-
 .../java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessageConverter.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessageConverter.java
index 96532cd..f595848 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessageConverter.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessageConverter.java
@@ -247,7 +247,7 @@ public class RabbitMQMessageConverter {
             message.setHeader(RabbitMQConstants.ROUTING_KEY, envelope.getRoutingKey());
             message.setHeader(RabbitMQConstants.EXCHANGE_NAME, envelope.getExchange());
             message.setHeader(RabbitMQConstants.DELIVERY_TAG, envelope.getDeliveryTag());
-            message.setHeader(RabbitMQConstants.REDELIVERY_TAG, envelope.isRedelivery());
+            message.setHeader(RabbitMQConstants.REDELIVERY_TAG, envelope.isRedeliver());
         }
     }
 
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 7b9c267..f998a08 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
@@ -78,7 +78,7 @@ public class RabbitMQEndpointTest extends CamelTestSupport {
         Mockito.when(envelope.getRoutingKey()).thenReturn(routingKey);
         Mockito.when(envelope.getExchange()).thenReturn(exchangeName);
         Mockito.when(envelope.getDeliveryTag()).thenReturn(tag);
-        Mockito.when(envelope.isRedelivery()).thenReturn(redelivery);
+        Mockito.when(envelope.isRedeliver()).thenReturn(redelivery);
         Mockito.when(properties.getHeaders()).thenReturn(null);
 
         byte[] body = new byte[20];

-- 
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <co...@camel.apache.org>.