From 6aaa9df49f86e57b6e0b241605738ae4c80b8031 Mon Sep 17 00:00:00 2001 From: jbertram Date: Thu, 5 May 2016 08:24:09 -0500 Subject: [PATCH] Improve packet toString() to ease debug --- .../impl/wireformat/CheckFailoverMessage.java | 8 ++++++++ .../wireformat/CheckFailoverReplyMessage.java | 8 ++++++++ .../ClusterTopologyChangeMessage.java | 11 +++++++++++ .../ClusterTopologyChangeMessage_V2.java | 13 +++++++++++++ .../ClusterTopologyChangeMessage_V3.java | 14 ++++++++++++++ .../impl/wireformat/CreateSessionMessage.java | 19 +++++++++++++++++++ .../CreateSessionResponseMessage.java | 8 ++++++++ .../wireformat/CreateSharedQueueMessage.java | 3 ++- .../wireformat/DisconnectConsumerMessage.java | 8 ++++++++ .../core/impl/wireformat/MessagePacket.java | 5 ++--- .../wireformat/ReattachSessionMessage.java | 9 +++++++++ .../ReattachSessionResponseMessage.java | 9 +++++++++ .../core/impl/wireformat/RollbackMessage.java | 8 ++++++++ .../wireformat/SessionAcknowledgeMessage.java | 10 ++++++++++ .../wireformat/SessionAddMetaDataMessage.java | 9 +++++++++ .../SessionAddMetaDataMessageV2.java | 10 ++++++++++ .../SessionBindingQueryMessage.java | 8 ++++++++ .../SessionBindingQueryResponseMessage.java | 9 +++++++++ ...SessionBindingQueryResponseMessage_V2.java | 10 ++++++++++ .../SessionContinuationMessage.java | 9 +++++++++ .../SessionCreateConsumerMessage.java | 3 +++ .../impl/wireformat/SessionExpireMessage.java | 9 +++++++++ .../SessionIndividualAcknowledgeMessage.java | 10 ++++++++++ .../SessionProducerCreditsFailMessage.java | 9 +++++++++ .../SessionProducerCreditsMessage.java | 9 +++++++++ .../wireformat/SessionQueueQueryMessage.java | 8 ++++++++ .../SessionQueueQueryResponseMessage.java | 15 +++++++++++++++ .../SessionQueueQueryResponseMessage_V2.java | 16 ++++++++++++++++ .../SessionReceiveContinuationMessage.java | 8 ++++++++ .../SessionReceiveLargeMessage.java | 11 +++++++++++ .../wireformat/SessionReceiveMessage.java | 9 +++++++++ .../SessionRequestProducerCreditsMessage.java | 9 +++++++++ .../SessionSendContinuationMessage.java | 14 ++++++++++++++ .../wireformat/SessionSendLargeMessage.java | 8 ++++++++ .../impl/wireformat/SessionSendMessage.java | 8 ++++++++ .../SessionXAAfterFailedMessage.java | 8 ++++++++ .../wireformat/SessionXAForgetMessage.java | 8 ++++++++ ...essionXAGetInDoubtXidsResponseMessage.java | 8 ++++++++ .../SessionXAGetTimeoutResponseMessage.java | 8 ++++++++ .../impl/wireformat/SessionXAJoinMessage.java | 8 ++++++++ .../wireformat/SessionXAPrepareMessage.java | 8 ++++++++ .../wireformat/SessionXAResponseMessage.java | 10 ++++++++++ .../wireformat/SessionXAResumeMessage.java | 8 ++++++++ .../wireformat/SessionXARollbackMessage.java | 8 ++++++++ .../SessionXASetTimeoutMessage.java | 8 ++++++++ .../SessionXASetTimeoutResponseMessage.java | 8 ++++++++ .../wireformat/SessionXAStartMessage.java | 8 ++++++++ ...ubscribeClusterTopologyUpdatesMessage.java | 8 ++++---- ...scribeClusterTopologyUpdatesMessageV2.java | 8 ++++++++ 49 files changed, 440 insertions(+), 8 deletions(-) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverMessage.java index c618e0b0a3..902ff1f283 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverMessage.java @@ -42,6 +42,14 @@ public class CheckFailoverMessage extends PacketImpl { nodeID = buffer.readNullableString(); } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", nodeID=" + nodeID); + buff.append("]"); + return buff.toString(); + } + public String getNodeID() { return nodeID; } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java index e09f28259d..1173e10938 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java @@ -47,6 +47,14 @@ public class CheckFailoverReplyMessage extends PacketImpl { okToFailover = buffer.readBoolean(); } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", okToFailover=" + okToFailover); + buff.append("]"); + return buff.toString(); + } + public boolean isOkToFailover() { return okToFailover; } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java index 48c786281b..b799f6e602 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java @@ -148,6 +148,17 @@ public class ClusterTopologyChangeMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", exit=" + exit); + buff.append(", last=" + last); + buff.append(", nodeID=" + nodeID); + buff.append(", pair=" + pair); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) { diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java index a39dda901a..7e0450acb2 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java @@ -143,6 +143,19 @@ public class ClusterTopologyChangeMessage_V2 extends ClusterTopologyChangeMessag return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", exit=" + exit); + buff.append(", last=" + last); + buff.append(", nodeID=" + nodeID); + buff.append(", pair=" + pair); + buff.append(", backupGroupName=" + backupGroupName); + buff.append(", uniqueEventID=" + uniqueEventID); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) { diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java index 3942708bae..d5ade55077 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java @@ -75,6 +75,20 @@ public class ClusterTopologyChangeMessage_V3 extends ClusterTopologyChangeMessag return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", exit=" + exit); + buff.append(", last=" + last); + buff.append(", nodeID=" + nodeID); + buff.append(", pair=" + pair); + buff.append(", backupGroupName=" + backupGroupName); + buff.append(", uniqueEventID=" + uniqueEventID); + buff.append(", scaleDownGroupName=" + scaleDownGroupName); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) { diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionMessage.java index b18821a12c..57bae7c0cc 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionMessage.java @@ -194,6 +194,25 @@ public class CreateSessionMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", autoCommitAcks=" + autoCommitAcks); + buff.append(", autoCommitSends=" + autoCommitSends); + buff.append(", defaultAddress=" + defaultAddress); + buff.append(", minLargeMessageSize=" + minLargeMessageSize); + buff.append(", name=" + name); + buff.append(", password=" + password); + buff.append(", preAcknowledge=" + preAcknowledge); + buff.append(", sessionChannelID=" + sessionChannelID); + buff.append(", username=" + username); + buff.append(", version=" + version); + buff.append(", windowSize=" + windowSize); + buff.append(", xa=" + xa); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java index 6f15777d1c..1c56a85cb7 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java @@ -78,4 +78,12 @@ public class CreateSessionResponseMessage extends PacketImpl { return false; return true; } + + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", serverVersion=" + serverVersion); + buff.append("]"); + return buff.toString(); + } } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java index 8191f1699c..9911490c1e 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java @@ -58,7 +58,8 @@ public class CreateSharedQueueMessage extends PacketImpl { buff.append(", address=" + address); buff.append(", queueName=" + queueName); buff.append(", filterString=" + filterString); - buff.append(", durable=" + filterString); + buff.append(", durable=" + durable); + buff.append(", requiresResponse=" + requiresResponse); buff.append("]"); return buff.toString(); } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java index 540bc37075..9eacc1dd2b 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java @@ -42,6 +42,14 @@ public class DisconnectConsumerMessage extends PacketImpl { consumerId = buffer.readLong(); } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerId=" + consumerId); + buff.append("]"); + return buff.toString(); + } + public long getConsumerId() { return consumerId; } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/MessagePacket.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/MessagePacket.java index 75bc879088..72f3602daa 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/MessagePacket.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/MessagePacket.java @@ -36,9 +36,8 @@ public abstract class MessagePacket extends PacketImpl implements MessagePacketI } @Override - public String toString() { - return this.getParentString() + ",message=" + message + "]"; - + public String getParentString() { + return super.getParentString() + ", message=" + message; } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionMessage.java index db35eac3c2..406347b82c 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionMessage.java @@ -71,6 +71,15 @@ public class ReattachSessionMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", lastConfirmedCommandID=" + lastConfirmedCommandID); + buff.append(", name=" + name); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java index 89c59b6c6e..399e9fb768 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java @@ -78,6 +78,15 @@ public class ReattachSessionResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", lastConfirmedCommandID=" + lastConfirmedCommandID); + buff.append(", reattached=" + reattached); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/RollbackMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/RollbackMessage.java index f9f947914c..26c08ef349 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/RollbackMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/RollbackMessage.java @@ -65,6 +65,14 @@ public class RollbackMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", considerLastMessageAsDelivered=" + considerLastMessageAsDelivered); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java index 45a4a25364..542c34cc00 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java @@ -83,6 +83,16 @@ public class SessionAcknowledgeMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append(", messageID=" + messageID); + buff.append(", requiresResponse=" + requiresResponse); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java index b54336e28e..76a28f8d86 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java @@ -73,6 +73,15 @@ public class SessionAddMetaDataMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", key=" + key); + buff.append(", data=" + data); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java index d0d12fccb4..eb16edaf32 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java @@ -97,6 +97,16 @@ public class SessionAddMetaDataMessageV2 extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", key=" + key); + buff.append(", data=" + data); + buff.append(", requiresConfirmation=" + requiresConfirmation); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java index 73cf603276..6a901ae25c 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java @@ -56,6 +56,14 @@ public class SessionBindingQueryMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", address=" + address); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java index 65a0d254b2..6197faf0c3 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java @@ -89,6 +89,15 @@ public class SessionBindingQueryResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", exists=" + exists); + buff.append(", queueNames=" + queueNames); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java index 269633c7d6..55da268585 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java @@ -65,6 +65,16 @@ public class SessionBindingQueryResponseMessage_V2 extends SessionBindingQueryRe return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", exists=" + exists); + buff.append(", queueNames=" + queueNames); + buff.append(", autoCreateJmsQueues=" + autoCreateJmsQueues); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionContinuationMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionContinuationMessage.java index 901837bc7d..135aac5a55 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionContinuationMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionContinuationMessage.java @@ -86,6 +86,15 @@ public abstract class SessionContinuationMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", body=" + Arrays.toString(body)); + buff.append(", continues=" + continues); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java index bae39d2f77..42ff65afc4 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java @@ -55,6 +55,9 @@ public class SessionCreateConsumerMessage extends PacketImpl { StringBuffer buff = new StringBuffer(getParentString()); buff.append(", queueName=" + queueName); buff.append(", filterString=" + filterString); + buff.append(", id=" + id); + buff.append(", browseOnly=" + browseOnly); + buff.append(", requiresResponse=" + requiresResponse); buff.append("]"); return buff.toString(); } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionExpireMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionExpireMessage.java index 48e9ea4fd1..e48e60d11a 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionExpireMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionExpireMessage.java @@ -77,6 +77,15 @@ public class SessionExpireMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append(", messageID=" + messageID); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java index 6ca5f88672..7d06081d60 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java @@ -92,6 +92,16 @@ public class SessionIndividualAcknowledgeMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append(", messageID=" + messageID); + buff.append(", requiresResponse=" + requiresResponse); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java index 6e995bae6c..6c194b8cc9 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java @@ -67,6 +67,15 @@ public class SessionProducerCreditsFailMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", address=" + address); + buff.append(", credits=" + credits); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java index c2bd339852..d672b0ef93 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java @@ -67,6 +67,15 @@ public class SessionProducerCreditsMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", address=" + address); + buff.append(", credits=" + credits); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java index df38bf4e38..98ae9460e1 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java @@ -56,6 +56,14 @@ public class SessionQueueQueryMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", queueName=" + queueName); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java index edd7a4ff04..e66b4eb155 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java @@ -156,6 +156,21 @@ public class SessionQueueQueryResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", address=" + address); + buff.append(", name=" + name); + buff.append(", consumerCount=" + consumerCount); + buff.append(", filterString=" + filterString); + buff.append(", durable=" + durable); + buff.append(", exists=" + exists); + buff.append(", temporary=" + temporary); + buff.append(", messageCount=" + messageCount); + buff.append("]"); + return buff.toString(); + } + public ClientSession.QueueQuery toQueueQuery() { return new QueueQueryImpl(isDurable(), isTemporary(), getConsumerCount(), getMessageCount(), getFilterString(), getAddress(), getName(), isExists()); } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java index 8c1b153273..77ad0f32c8 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java @@ -88,6 +88,22 @@ public class SessionQueueQueryResponseMessage_V2 extends SessionQueueQueryRespon return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", address=" + address); + buff.append(", name=" + name); + buff.append(", consumerCount=" + consumerCount); + buff.append(", filterString=" + filterString); + buff.append(", durable=" + durable); + buff.append(", exists=" + exists); + buff.append(", temporary=" + temporary); + buff.append(", messageCount=" + messageCount); + buff.append(", autoCreationEnabled=" + autoCreationEnabled); + buff.append("]"); + return buff.toString(); + } + @Override public ClientSession.QueueQuery toQueueQuery() { return new QueueQueryImpl(isDurable(), isTemporary(), getConsumerCount(), getMessageCount(), getFilterString(), getAddress(), getName(), isExists(), isAutoCreationEnabled()); diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java index 7ed680acae..6748201a41 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java @@ -100,6 +100,14 @@ public class SessionReceiveContinuationMessage extends SessionContinuationMessag return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java index aa5d98fb4f..06805f08ea 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java @@ -108,6 +108,17 @@ public class SessionReceiveLargeMessage extends PacketImpl implements MessagePac return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append(", deliveryCount=" + deliveryCount); + buff.append(", largeMessageSize=" + largeMessageSize); + buff.append(", message=" + message); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveMessage.java index bccc9df406..02ed2bf383 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveMessage.java @@ -109,6 +109,15 @@ public class SessionReceiveMessage extends MessagePacket { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", consumerID=" + consumerID); + buff.append(", deliveryCount=" + deliveryCount); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java index 10fcd630bb..1627dfd967 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java @@ -74,6 +74,15 @@ public class SessionRequestProducerCreditsMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", credits=" + credits); + buff.append(", address=" + address); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java index 761b961434..dc7e1f0b20 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java @@ -16,6 +16,8 @@ */ package org.apache.activemq.artemis.core.protocol.core.impl.wireformat; +import java.util.Arrays; + import org.apache.activemq.artemis.api.core.ActiveMQBuffer; import org.apache.activemq.artemis.api.core.client.SendAcknowledgementHandler; import org.apache.activemq.artemis.core.message.impl.MessageInternal; @@ -119,6 +121,18 @@ public class SessionSendContinuationMessage extends SessionContinuationMessage { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", body=" + Arrays.toString(body)); + buff.append(", continues=" + continues); + buff.append(", message=" + message); + buff.append(", messageBodySize=" + messageBodySize); + buff.append(", requiresResponse=" + requiresResponse); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java index 3c7dbe79fc..9154a7de0c 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java @@ -67,6 +67,14 @@ public class SessionSendLargeMessage extends PacketImpl implements MessagePacket return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", largeMessage=" + largeMessage); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendMessage.java index 78d48621b1..4674ce0400 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionSendMessage.java @@ -118,6 +118,14 @@ public class SessionSendMessage extends MessagePacket { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", requiresResponse=" + requiresResponse); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java index 13700b570c..1727e42ef4 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java @@ -70,6 +70,14 @@ public class SessionXAAfterFailedMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java index 2f88745620..bbd110ef52 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java @@ -58,6 +58,14 @@ public class SessionXAForgetMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java index a78bad4a75..08cd4a8c7d 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java @@ -68,6 +68,14 @@ public class SessionXAGetInDoubtXidsResponseMessage extends PacketImpl { } } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xids=" + xids); + buff.append("]"); + return buff.toString(); + } + @Override public int hashCode() { final int prime = 31; diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java index 7f12ec63e5..f1a702aa04 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java @@ -60,6 +60,14 @@ public class SessionXAGetTimeoutResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", timeoutSeconds=" + timeoutSeconds); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java index dde0dfbdbb..99ddf18f24 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java @@ -58,6 +58,14 @@ public class SessionXAJoinMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java index 948c6dbdb0..24ef2eae72 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java @@ -58,6 +58,14 @@ public class SessionXAPrepareMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java index d19035b550..fa6c2961da 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java @@ -84,6 +84,16 @@ public class SessionXAResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", error=" + error); + buff.append(", message=" + message); + buff.append(", responseCode=" + responseCode); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java index dbb6eb05b3..fd801d4743 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java @@ -60,6 +60,14 @@ public class SessionXAResumeMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java index e7e337f22b..c42b7ae3d1 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java @@ -60,6 +60,14 @@ public class SessionXARollbackMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java index ff5d72e9a4..79406fee3e 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java @@ -57,6 +57,14 @@ public class SessionXASetTimeoutMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", timeoutSeconds=" + timeoutSeconds); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java index cc84c433e7..6ec69d4de0 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java @@ -62,6 +62,14 @@ public class SessionXASetTimeoutResponseMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", ok=" + ok); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAStartMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAStartMessage.java index 68b37c3372..d0bff0aec1 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAStartMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionXAStartMessage.java @@ -67,6 +67,14 @@ public class SessionXAStartMessage extends PacketImpl { return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", xid=" + xid); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java index 1b8abc95e0..6038577fa9 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java @@ -61,10 +61,10 @@ public class SubscribeClusterTopologyUpdatesMessage extends PacketImpl { @Override public String toString() { - return "SubscribeClusterTopologyUpdatesMessage [clusterConnection=" + clusterConnection + - ", toString()=" + - super.toString() + - "]"; + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", clusterConnection=" + clusterConnection); + buff.append("]"); + return buff.toString(); } @Override diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java index 2be74017a2..ac46a2c526 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java @@ -61,6 +61,14 @@ public class SubscribeClusterTopologyUpdatesMessageV2 extends SubscribeClusterTo return result; } + @Override + public String toString() { + StringBuffer buff = new StringBuffer(getParentString()); + buff.append(", clientVersion=" + clientVersion); + buff.append("]"); + return buff.toString(); + } + @Override public boolean equals(Object obj) { if (this == obj)