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 <roman_kalashni...@epam.com> Authored: Thu Mar 16 18:16:36 2017 +0300 Committer: Claus Ibsen <davscl...@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;
