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); } /**