CAMEL-11772 - Fix potential ClassCastException when creating the message ID in camel-sjms and camel-jms
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/16b7fbb5 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/16b7fbb5 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/16b7fbb5 Branch: refs/heads/master Commit: 16b7fbb5c403736085513d9a59d7311b9531eaf8 Parents: 46ef7a5 Author: Claus Ibsen <[email protected]> Authored: Wed Sep 13 09:45:17 2017 +0200 Committer: Claus Ibsen <[email protected]> Committed: Wed Sep 13 09:46:18 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/jms/JmsMessage.java | 9 ++++----- .../java/org/apache/camel/component/sjms/SjmsMessage.java | 7 +++---- 2 files changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/16b7fbb5/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java index 3fe42f7..fcd5610 100644 --- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java +++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java @@ -238,11 +238,10 @@ public class JmsMessage extends DefaultMessage { } try { String id = getDestinationAsString(jmsMessage.getJMSDestination()); - if(id != null) { + if (id != null) { id += jmsMessage.getJMSMessageID(); - } - else { - id = super.createMessageId(); + } else { + id = jmsMessage.getJMSMessageID(); } return getSanitizedString(id); } catch (JMSException e) { @@ -265,7 +264,7 @@ public class JmsMessage extends DefaultMessage { result = "null destination!" + File.separator; } else if (destination instanceof Topic) { result = "topic" + File.separator + ((Topic) destination).getTopicName() + File.separator; - } else if (destination instanceof Queue){ + } else if (destination instanceof Queue) { result = "queue" + File.separator + ((Queue) destination).getQueueName() + File.separator; } return result; http://git-wip-us.apache.org/repos/asf/camel/blob/16b7fbb5/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsMessage.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsMessage.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsMessage.java index 3abdd93..d352034 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsMessage.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsMessage.java @@ -251,11 +251,10 @@ public class SjmsMessage extends DefaultMessage { } try { String id = getDestinationAsString(jmsMessage.getJMSDestination()); - if(id != null) { + if (id != null) { id += jmsMessage.getJMSMessageID(); - } - else { - id = super.createMessageId(); + } else { + id = jmsMessage.getJMSMessageID(); } return getSanitizedString(id); } catch (JMSException e) {
