Repository: camel Updated Branches: refs/heads/camel-2.13.x 04a7feb9a -> 41d4d4a67
CAMEL-7571: Fixed potential NPE iin camel-rabbitmq f debug logging was enabled. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/41d4d4a6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/41d4d4a6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/41d4d4a6 Branch: refs/heads/camel-2.13.x Commit: 41d4d4a67b575c8b5a30c7cec7b1e9852f2623f2 Parents: 04a7feb Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Jul 3 08:08:49 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Jul 3 08:09:18 2014 +0200 ---------------------------------------------------------------------- .../apache/camel/component/rabbitmq/RabbitMQProducer.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/41d4d4a6/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java index 7763423..81360ae 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java @@ -177,8 +177,12 @@ public class RabbitMQProducer extends DefaultProducer { if (value != null) { filteredHeaders.put(header.getKey(), header.getValue()); } else if (log.isDebugEnabled()) { - log.debug("Ignoring header: {} of class: {} with value: {}", - new Object[]{header.getKey(), header.getValue().getClass().getName(), header.getValue()}); + if (header.getValue() == null) { + log.debug("Ignoring header: {} with null value", header.getKey()); + } else { + log.debug("Ignoring header: {} of class: {} with value: {}", + new Object[]{header.getKey(), ObjectHelper.classCanonicalName(header.getValue()), header.getValue()}); + } } }
