[camel] 02/15: Added support for rabbitmq x-max-priority

[acosentino]

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

acosentino pushed a commit to branch sandbox/camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 96f3ec087f76f59d8aa0e7fd0e5e7b694559b9fc
Author: Carlos R. B. Meneghette <carlo...@simepar.br>
AuthorDate: Wed Nov 28 00:32:42 2018 -0200

    Added support for rabbitmq x-max-priority
---
 .../java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java  | 1 +
 .../org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java  | 5 +++++
 2 files changed, 6 insertions(+)

diff --git 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
index d796a58..446d39f 100644
--- 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
+++ 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
@@ -46,6 +46,7 @@ public final class RabbitMQConstants {
     public static final String RABBITMQ_DIRECT_REPLY_EXCHANGE = "";
     public static final String RABBITMQ_DIRECT_REPLY_ROUTING_KEY = 
"amq.rabbitmq.reply-to";
     public static final String RABBITMQ_QUEUE_LENGTH_LIMIT_KEY = 
"x-max-length";
+    public static final String RABBITMQ_QUEUE_MAX_PRIORITY_KEY = 
"x-max-priority";
     public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = 
"x-message-ttl";
     public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires";
     
diff --git 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
index 0dafc46..1fff2e1 100644
--- 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
+++ 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
@@ -70,6 +70,11 @@ public class RabbitMQDeclareSupport {
         if (queueLengthLimit instanceof String) {
             queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGTH_LIMIT_KEY, 
Long.parseLong((String) queueLengthLimit));
         }
+        
+        Object queueMaxPriority = 
queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MAX_PRIORITY_KEY);
+        if (queueMaxPriority instanceof String) {
+            queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_MAX_PRIORITY_KEY, 
Integer.parseInt((String) queueMaxPriority));
+        }
 
         Object queueMessageTtl = 
queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY);
         if (queueMessageTtl instanceof String) {