diff options
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java index fbb55ae289..aaf0320afb 100644 --- a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java +++ b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java @@ -58,7 +58,8 @@ public abstract class AbstractJMSMessage extends AMQMessage implements javax.jms { _data.acquire(); } - _readableProperties = false; + // ContentHeaderProperties are just created and so are empty + //_readableProperties = (_contentHeaderProperties != null); _readableMessage = (data != null); } @@ -424,7 +425,15 @@ public abstract class AbstractJMSMessage extends AMQMessage implements javax.jms buf.append("\nJMS priority: ").append(getJMSPriority()); buf.append("\nJMS delivery mode: ").append(getJMSDeliveryMode()); buf.append("\nJMS reply to: ").append(String.valueOf(getJMSReplyTo())); + buf.append("\nJMS Type: ").append(String.valueOf(getJMSType())); + buf.append("\nJMS CorrelationID: ").append(String.valueOf(getJMSCorrelationID())); + buf.append("\nJMS Destination: NOT IMPLEMENTED");//.append(String.valueOf(getJMSDestination())); + buf.append("\nJMS MessageID: ").append(String.valueOf(getJMSMessageID())); + buf.append("\nJMS Redelivered: ").append(String.valueOf(getJMSRedelivered())); + buf.append("\nProperty Names: ").append(String.valueOf(getPropertyNames())); + buf.append("\nAMQ message number: ").append(_deliveryTag); + buf.append("\nProperties:"); if (getJmsContentHeaderProperties().getHeaders().isEmpty()) { |