summaryrefslogtreecommitdiff
path: root/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
diff options
context:
space:
mode:
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.java11
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())
{