diff options
Diffstat (limited to 'qpid/java/client/src/main')
2 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java index 73f089e4c9..ea0319c9df 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java @@ -746,7 +746,7 @@ public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate } else if (isStrictJMS && QpidMessageProperties.QPID_SUBJECT.equals(propertyName)) { - return (String)getApplicationHeaders().get("JMS_" + QpidMessageProperties.QPID_SUBJECT); + return (String)getApplicationHeaders().get("JMS_" + QpidMessageProperties.QPID_SUBJECT_JMS_PROPER); } else { diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/message/QpidMessageProperties.java b/qpid/java/client/src/main/java/org/apache/qpid/client/message/QpidMessageProperties.java index 663dfd39b1..21bb206349 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/message/QpidMessageProperties.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/message/QpidMessageProperties.java @@ -30,6 +30,7 @@ public class QpidMessageProperties } public static final String QPID_SUBJECT = "qpid.subject"; + public static final String QPID_SUBJECT_JMS_PROPER = "qpid_subject"; // AMQP 0-10 related properties public static final String AMQP_0_10_APP_ID = "x-amqp-0-10.app-id"; |