Add null handling Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/172cc5f5 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/172cc5f5 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/172cc5f5
Branch: refs/heads/master Commit: 172cc5f54401b3964418fdd524e47d514b0e9e63 Parents: 072f273 Author: hauler <[email protected]> Authored: Thu Mar 16 17:46:44 2017 +0300 Committer: Claus Ibsen <[email protected]> Committed: Wed Mar 22 21:31:28 2017 +0100 ---------------------------------------------------------------------- .../apache/camel/component/rabbitmq/RabbitMQMessagePublisher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/172cc5f5/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 c7fee3c..876c701 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,7 +70,7 @@ public class RabbitMQMessagePublisher { LOG.debug("Removing the {} header", RabbitMQEndpoint.SERIALIZE_HEADER); message.getHeaders().remove(RabbitMQEndpoint.SERIALIZE_HEADER); } - if (routingKey.startsWith("amq.rabbitmq.reply-to")) { + if (routingKey != null && routingKey.startsWith("amq.rabbitmq.reply-to")) { message.setHeader(RabbitMQConstants.EXCHANGE_NAME, ""); // use default exchange for reply-to messages }
