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/03/22 20:43:00 UTC
[4/7] camel git commit: Introduce direct reply constants
Introduce direct reply constants
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/63b0dbd4
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/63b0dbd4
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/63b0dbd4
Branch: refs/heads/master
Commit: 63b0dbd4dc079749d9d09ce5ca684a49fd280b6a
Parents: 172cc5f
Author: Roman Kalashnikov <ro...@epam.com>
Authored: Thu Mar 16 18:16:36 2017 +0300
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Mar 22 21:31:28 2017 +0100
----------------------------------------------------------------------
.../org/apache/camel/component/rabbitmq/RabbitMQConstants.java | 2 ++
.../camel/component/rabbitmq/RabbitMQMessagePublisher.java | 4 ++--
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/63b0dbd4/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 cf4ab45..0ae82b2 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
@@ -40,6 +40,8 @@ public final class RabbitMQConstants {
public static final String IMMEDIATE = "rabbitmq.IMMEDIATE";
public static final String RABBITMQ_DEAD_LETTER_EXCHANGE = "x-dead-letter-exchange";
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";
private RabbitMQConstants() {
//Constants class
http://git-wip-us.apache.org/repos/asf/camel/blob/63b0dbd4/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java
----------------------------------------------------------------------
diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java
index 876c701..85e657f 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java
@@ -70,8 +70,8 @@ public class RabbitMQMessagePublisher {
LOG.debug("Removing the {} header", RabbitMQEndpoint.SERIALIZE_HEADER);
message.getHeaders().remove(RabbitMQEndpoint.SERIALIZE_HEADER);
}
- if (routingKey != null && routingKey.startsWith("amq.rabbitmq.reply-to")) {
- message.setHeader(RabbitMQConstants.EXCHANGE_NAME, ""); // use default exchange for reply-to messages
+ if (routingKey != null && routingKey.startsWith(RabbitMQConstants.RABBITMQ_DIRECT_REPLY_ROUTING_KEY)) {
+ message.setHeader(RabbitMQConstants.EXCHANGE_NAME, RabbitMQConstants.RABBITMQ_DIRECT_REPLY_EXCHANGE); // use default exchange for reply-to messages
}
return message;