You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by da...@apache.org on 2016/08/20 10:16:41 UTC
[2/2] activemq git commit: AMQ-6402: Fixed potential NPE in
OriginalDestinationPropagateStrategy
AMQ-6402: Fixed potential NPE in OriginalDestinationPropagateStrategy
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/853e8006
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/853e8006
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/853e8006
Branch: refs/heads/activemq-5.14.x
Commit: 853e80063bd51409ac646b034b99ac934e4d1870
Parents: 124bd1a
Author: Claus Ibsen <cl...@gmail.com>
Authored: Sat Aug 20 12:13:55 2016 +0200
Committer: Claus Ibsen <cl...@gmail.com>
Committed: Sat Aug 20 12:16:31 2016 +0200
----------------------------------------------------------------------
.../camel/component/OriginalDestinationPropagateStrategy.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/853e8006/activemq-camel/src/main/java/org/apache/activemq/camel/component/OriginalDestinationPropagateStrategy.java
----------------------------------------------------------------------
diff --git a/activemq-camel/src/main/java/org/apache/activemq/camel/component/OriginalDestinationPropagateStrategy.java b/activemq-camel/src/main/java/org/apache/activemq/camel/component/OriginalDestinationPropagateStrategy.java
index 84de369..8f4c9fd 100644
--- a/activemq-camel/src/main/java/org/apache/activemq/camel/component/OriginalDestinationPropagateStrategy.java
+++ b/activemq-camel/src/main/java/org/apache/activemq/camel/component/OriginalDestinationPropagateStrategy.java
@@ -40,7 +40,7 @@ public class OriginalDestinationPropagateStrategy implements MessageCreatedStrat
if (exchange.getIn() instanceof JmsMessage) {
JmsMessage msg = exchange.getIn(JmsMessage.class);
Message jms = msg.getJmsMessage();
- if (message instanceof ActiveMQMessage) {
+ if (jms != null && jms instanceof ActiveMQMessage && message instanceof ActiveMQMessage) {
ActiveMQMessage amq = (ActiveMQMessage) jms;
if (amq.getOriginalDestination() == null) {
ActiveMQDestination from = amq.getDestination();