summaryrefslogtreecommitdiff
path: root/qpid/java/client
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2011-08-02 21:19:07 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2011-08-02 21:19:07 +0000
commitf94c88c2044088d6857f6f2cc02545fc25dd8b85 (patch)
treec083e584feb38b1937348bc6df9c950020b36632 /qpid/java/client
parent437670e7ae583cbf62458096ac7a8253eea2e6de (diff)
downloadqpid-python-f94c88c2044088d6857f6f2cc02545fc25dd8b85.tar.gz
QPID-3381 Provided the ability to retrieve the routing key from a JMS message using getStringProperty().
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1153274 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java9
1 files changed, 7 insertions, 2 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 c9a42638b5..182b7b65d8 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
@@ -634,11 +634,16 @@ public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate
{
return new String(_messageProps.getUserId());
}
- else if ("x-amqp-0-10.app-id".equals(propertyName) &&
+ else if (QpidMessageProperties.AMQP_0_10_APP_ID.equals(propertyName) &&
_messageProps.getAppId() != null)
{
return new String(_messageProps.getAppId());
}
+ else if (QpidMessageProperties.AMQP_0_10_ROUTING_KEY.equals(propertyName) &&
+ _deliveryProps.getRoutingKey() != null)
+ {
+ return _deliveryProps.getRoutingKey();
+ }
else
{
checkPropertyName(propertyName);
@@ -745,7 +750,7 @@ public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate
{
checkPropertyName(propertyName);
checkWritableProperties();
- if ("x-amqp-0-10.app-id".equals(propertyName))
+ if (QpidMessageProperties.AMQP_0_10_APP_ID.equals(propertyName))
{
_messageProps.setAppId(value.getBytes());
}