[camel] branch master updated: CAMEL-15086: camel-rabbitmq - Args should be kept when configuring consumers as they would otherwise be lost when you use concurrent consumers 2 or higher.

[davsclaus]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 319d2f9  CAMEL-15086: camel-rabbitmq - Args should be kept when 
configuring consumers as they would otherwise be lost when you use concurrent 
consumers 2 or higher.
319d2f9 is described below

commit 319d2f985bf62c711a4b2aec8bbf89cd7e10cb35
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed May 20 07:02:29 2020 +0200

    CAMEL-15086: camel-rabbitmq - Args should be kept when configuring 
consumers as they would otherwise be lost when you use concurrent consumers 2 
or higher.
---
 .../java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
index 7171757..973a999 100644
--- 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
+++ 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
@@ -821,15 +821,15 @@ public class RabbitMQEndpoint extends DefaultEndpoint 
implements AsyncEndpoint {
     }
 
     public Map<String, Object> getExchangeArgs() {
-        return PropertiesHelper.extractProperties(args, EXCHANGE_ARG_PREFIX);
+        return PropertiesHelper.extractProperties(args, EXCHANGE_ARG_PREFIX, 
false);
     }
 
     public Map<String, Object> getQueueArgs() {
-        return PropertiesHelper.extractProperties(args, QUEUE_ARG_PREFIX);
+        return PropertiesHelper.extractProperties(args, QUEUE_ARG_PREFIX, 
false);
     }
 
     public Map<String, Object> getBindingArgs() {
-        return PropertiesHelper.extractProperties(args, BINDING_ARG_PREFIX);
+        return PropertiesHelper.extractProperties(args, BINDING_ARG_PREFIX, 
false);
     }
 
     /**