Author: rajith
Date: Tue Jun 28 03:03:30 2011
New Revision: 1140412
URL: http://svn.apache.org/viewvc?rev=1140412&view=rev
Log:
QPID-3302 You can now get and set the app-id in AMQP 0-10 message properties
using "x-amqp-0-10.app-id".
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java?rev=1140412&r1=1140411&r2=1140412&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java
Tue Jun 28 03:03:30 2011
@@ -634,6 +634,11 @@ public class AMQMessageDelegate_0_10 ext
{
return new String(_messageProps.getUserId());
}
+ else if ("x-amqp-0-10.app-id".equals(propertyName) &&
+ _messageProps.getAppId() != null)
+ {
+ return new String(_messageProps.getAppId());
+ }
else
{
checkPropertyName(propertyName);
@@ -740,7 +745,14 @@ public class AMQMessageDelegate_0_10 ext
{
checkPropertyName(propertyName);
checkWritableProperties();
- setApplicationHeader(propertyName, value);
+ if ("x-amqp-0-10.app-id".equals(propertyName))
+ {
+ _messageProps.setAppId(value.getBytes());
+ }
+ else
+ {
+ setApplicationHeader(propertyName, value);
+ }
}
private static final Set<Class> ALLOWED = new HashSet();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
