use the x-opt-jms-type annotation for transmitting the JMSType header
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/6d80d99e Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/6d80d99e Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/6d80d99e Branch: refs/heads/master Commit: 6d80d99e29884230d5f1ba3be7f9d9968ef2911a Parents: c294a3c Author: Robert Gemmell <rob...@apache.org> Authored: Mon Sep 29 11:54:41 2014 +0100 Committer: Robert Gemmell <rob...@apache.org> Committed: Mon Sep 29 17:09:37 2014 +0100 ---------------------------------------------------------------------- .../qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java | 5 +++-- .../qpid/jms/provider/amqp/message/AmqpMessageSupport.java | 6 ++++-- 2 files changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6d80d99e/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java index 5a514b8..6f9cc97 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java @@ -19,6 +19,7 @@ package org.apache.qpid.jms.provider.amqp.message; import static org.apache.qpid.jms.provider.amqp.message.AmqpMessageSupport.JMS_AMQP_TTL; import static org.apache.qpid.jms.provider.amqp.message.AmqpMessageSupport.JMS_MESSAGE; import static org.apache.qpid.jms.provider.amqp.message.AmqpMessageSupport.JMS_MSG_TYPE; +import static org.apache.qpid.jms.provider.amqp.message.AmqpMessageSupport.JMS_TYPE; import java.nio.ByteBuffer; import java.nio.charset.Charset; @@ -495,12 +496,12 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade { @Override public String getType() { - return (String) getAnnotation(JMS_MSG_TYPE); + return (String) getAnnotation(JMS_TYPE); } @Override public void setType(String type) { - setAnnotation(JMS_MSG_TYPE, type); + setAnnotation(JMS_TYPE, type); } @Override http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6d80d99e/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpMessageSupport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpMessageSupport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpMessageSupport.java index 70b1c57..0812208 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpMessageSupport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpMessageSupport.java @@ -81,12 +81,14 @@ public final class AmqpMessageSupport { public static final String JMS_APP_CORRELATION_ID = "x-opt-app-correlation-id"; /** - * Attribute used to mark the JMSType value set on the message. + * Attribute used to mark the JMSType header string value set on the message by + * an application. */ public static final String JMS_TYPE = "x-opt-jms-type"; /** - * Attribute used to mark the JMS Type that the message instance represents. + * Attribute used to mark the class type of JMS message that a particular message + * instance represents, used internally by the client. */ public static final String JMS_MSG_TYPE = "x-opt-jms-msg-type"; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
