You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/10/06 08:30:06 UTC
[1/4] camel git commit: CAMEL-11881: Handling special arguments when
declaring queues
Repository: camel
Updated Branches:
refs/heads/camel-2.19.x 2b8e5adca -> ebb467848
refs/heads/master 497f51e3a -> 8ab9bc408
CAMEL-11881: Handling special arguments when declaring queues
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7dfd373e
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7dfd373e
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7dfd373e
Branch: refs/heads/master
Commit: 7dfd373eda68c17dd5efec952eaeab048ca99b9f
Parents: 497f51e
Author: Veiga Ortiz, Héctor <he...@here.com>
Authored: Thu Oct 5 19:16:32 2017 -0500
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 6 10:27:12 2017 +0200
----------------------------------------------------------------------
.../component/rabbitmq/RabbitMQConstants.java | 3 +++
.../rabbitmq/RabbitMQDeclareSupport.java | 18 ++++++++++++++++++
2 files changed, 21 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/7dfd373e/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
----------------------------------------------------------------------
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 0ae82b2..fc6a326 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
@@ -42,6 +42,9 @@ public final class RabbitMQConstants {
public static final String RABBITMQ_DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
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_LENGHT_LIMIT_KEY = "x-max-length";
+ public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl";
+ public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires";
private RabbitMQConstants() {
//Constants class
http://git-wip-us.apache.org/repos/asf/camel/blob/7dfd373e/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
----------------------------------------------------------------------
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 90e993e..982dd27 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
@@ -61,9 +61,27 @@ public class RabbitMQDeclareSupport {
populateQueueArgumentsFromDeadLetterExchange(queueArgs);
populateQueueArgumentsFromConfigurer(queueArgs);
queueArgs.putAll(endpoint.getQueueArgs());
+ formatSpecialQueueArguments(queueArgs);
return queueArgs;
}
+ private void formatSpecialQueueArguments(Map<String, Object> queueArgs) {
+ Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY);
+ if (queueLengthLimit != null && queueLengthLimit instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
+ }
+
+ Object queueMessageTtl = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY);
+ if (queueMessageTtl != null && queueMessageTtl instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY, Long.parseLong((String) queueMessageTtl));
+ }
+
+ Object queueExpiration = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY);
+ if (queueExpiration != null && queueExpiration instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, Long.parseLong((String) queueExpiration));
+ }
+ }
+
private Map<String, Object> populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
if (endpoint.getDeadLetterExchange() != null) {
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_EXCHANGE, endpoint.getDeadLetterExchange());
[3/4] camel git commit: CAMEL-11881: Handling special arguments when
declaring queues
Posted by da...@apache.org.
CAMEL-11881: Handling special arguments when declaring queues
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a57a06e6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a57a06e6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a57a06e6
Branch: refs/heads/camel-2.19.x
Commit: a57a06e609970427bb58e0e7a2215fe7352824e6
Parents: 2b8e5ad
Author: Veiga Ortiz, Héctor <he...@here.com>
Authored: Thu Oct 5 19:16:32 2017 -0500
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 6 10:29:50 2017 +0200
----------------------------------------------------------------------
.../component/rabbitmq/RabbitMQConstants.java | 3 +++
.../rabbitmq/RabbitMQDeclareSupport.java | 18 ++++++++++++++++++
2 files changed, 21 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a57a06e6/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
----------------------------------------------------------------------
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 0ae82b2..fc6a326 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
@@ -42,6 +42,9 @@ public final class RabbitMQConstants {
public static final String RABBITMQ_DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
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_LENGHT_LIMIT_KEY = "x-max-length";
+ public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl";
+ public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires";
private RabbitMQConstants() {
//Constants class
http://git-wip-us.apache.org/repos/asf/camel/blob/a57a06e6/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
----------------------------------------------------------------------
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 b38eae9..03fc325 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
@@ -60,9 +60,27 @@ public class RabbitMQDeclareSupport {
populateQueueArgumentsFromDeadLetterExchange(queueArgs);
populateQueueArgumentsFromConfigurer(queueArgs);
queueArgs.putAll(endpoint.getQueueArgs());
+ formatSpecialQueueArguments(queueArgs);
return queueArgs;
}
+ private void formatSpecialQueueArguments(Map<String, Object> queueArgs) {
+ Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY);
+ if (queueLengthLimit != null && queueLengthLimit instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
+ }
+
+ Object queueMessageTtl = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY);
+ if (queueMessageTtl != null && queueMessageTtl instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY, Long.parseLong((String) queueMessageTtl));
+ }
+
+ Object queueExpiration = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY);
+ if (queueExpiration != null && queueExpiration instanceof String) {
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, Long.parseLong((String) queueExpiration));
+ }
+ }
+
private Map<String, Object> populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
if (endpoint.getDeadLetterExchange() != null) {
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_EXCHANGE, endpoint.getDeadLetterExchange());
[2/4] camel git commit: Polished and fixed typo. This closes #2010
Posted by da...@apache.org.
Polished and fixed typo. This closes #2010
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8ab9bc40
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8ab9bc40
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8ab9bc40
Branch: refs/heads/master
Commit: 8ab9bc4085d4316e381acf0beca333f0ad774402
Parents: 7dfd373
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Oct 6 10:29:21 2017 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 6 10:29:21 2017 +0200
----------------------------------------------------------------------
.../apache/camel/component/rabbitmq/RabbitMQConstants.java | 2 +-
.../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 9 ++++-----
2 files changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/8ab9bc40/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
----------------------------------------------------------------------
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 fc6a326..cc7bf32 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
@@ -42,7 +42,7 @@ public final class RabbitMQConstants {
public static final String RABBITMQ_DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
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_LENGHT_LIMIT_KEY = "x-max-length";
+ public static final String RABBITMQ_QUEUE_LENGTH_LIMIT_KEY = "x-max-length";
public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl";
public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires";
http://git-wip-us.apache.org/repos/asf/camel/blob/8ab9bc40/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
----------------------------------------------------------------------
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 982dd27..99c425a 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
@@ -66,9 +66,10 @@ public class RabbitMQDeclareSupport {
}
private void formatSpecialQueueArguments(Map<String, Object> queueArgs) {
- Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY);
+ // some arguments must be in numeric values so we need to fix this
+ Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGTH_LIMIT_KEY);
if (queueLengthLimit != null && queueLengthLimit instanceof String) {
- queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGTH_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
}
Object queueMessageTtl = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY);
@@ -82,13 +83,11 @@ public class RabbitMQDeclareSupport {
}
}
- private Map<String, Object> populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
+ private void populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
if (endpoint.getDeadLetterExchange() != null) {
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_EXCHANGE, endpoint.getDeadLetterExchange());
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_ROUTING_KEY, endpoint.getDeadLetterRoutingKey());
}
-
- return queueArgs;
}
private Map<String, Object> resolvedExchangeArguments() {
[4/4] camel git commit: Polished and fixed typo. This closes #2010
Posted by da...@apache.org.
Polished and fixed typo. This closes #2010
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ebb46784
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ebb46784
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ebb46784
Branch: refs/heads/camel-2.19.x
Commit: ebb467848b1f55b2509d4df908c3d7a5de984db5
Parents: a57a06e
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Oct 6 10:29:21 2017 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 6 10:29:59 2017 +0200
----------------------------------------------------------------------
.../apache/camel/component/rabbitmq/RabbitMQConstants.java | 2 +-
.../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 9 ++++-----
2 files changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/ebb46784/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java
----------------------------------------------------------------------
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 fc6a326..cc7bf32 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
@@ -42,7 +42,7 @@ public final class RabbitMQConstants {
public static final String RABBITMQ_DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
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_LENGHT_LIMIT_KEY = "x-max-length";
+ public static final String RABBITMQ_QUEUE_LENGTH_LIMIT_KEY = "x-max-length";
public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl";
public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires";
http://git-wip-us.apache.org/repos/asf/camel/blob/ebb46784/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java
----------------------------------------------------------------------
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 03fc325..391f086 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
@@ -65,9 +65,10 @@ public class RabbitMQDeclareSupport {
}
private void formatSpecialQueueArguments(Map<String, Object> queueArgs) {
- Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY);
+ // some arguments must be in numeric values so we need to fix this
+ Object queueLengthLimit = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_LENGTH_LIMIT_KEY);
if (queueLengthLimit != null && queueLengthLimit instanceof String) {
- queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGHT_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
+ queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_LENGTH_LIMIT_KEY, Long.parseLong((String) queueLengthLimit));
}
Object queueMessageTtl = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_MESSAGE_TTL_KEY);
@@ -81,13 +82,11 @@ public class RabbitMQDeclareSupport {
}
}
- private Map<String, Object> populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
+ private void populateQueueArgumentsFromDeadLetterExchange(final Map<String, Object> queueArgs) {
if (endpoint.getDeadLetterExchange() != null) {
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_EXCHANGE, endpoint.getDeadLetterExchange());
queueArgs.put(RabbitMQConstants.RABBITMQ_DEAD_LETTER_ROUTING_KEY, endpoint.getDeadLetterRoutingKey());
}
-
- return queueArgs;
}
private Map<String, Object> resolvedExchangeArguments() {