diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-08-02 21:19:07 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-08-02 21:19:07 +0000 |
| commit | 1e77d547d7b8fb2bf151b8b5c9d3083d3bceb1a3 (patch) | |
| tree | 5917e94373e5138a71f2711383def0e30204c741 /java/client | |
| parent | fdc9d6071712672e5c9671e013ad63e3dd6b624d (diff) | |
| download | qpid-python-1e77d547d7b8fb2bf151b8b5c9d3083d3bceb1a3.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/qpid@1153274 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java b/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java index c9a42638b5..182b7b65d8 100644 --- a/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java +++ b/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()); } |
