Log more info when inter-Node messaging fails.
Change-Id: Ifd749a3023854d688a675c7279c27868b8bed436
diff --git a/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/ClusterCommunicationManager.java b/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/ClusterCommunicationManager.java
index 2868270..070e1fe 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/ClusterCommunicationManager.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/ClusterCommunicationManager.java
@@ -194,7 +194,7 @@
try {
clusterMessage = SERIALIZER.decode(message.payload());
} catch (Exception e) {
- log.error("Failed decoding ClusterMessage", e);
+ log.error("Failed decoding ClusterMessage {}", message, e);
throw e;
}
try {
diff --git a/utils/netty/src/main/java/org/onlab/netty/InternalMessage.java b/utils/netty/src/main/java/org/onlab/netty/InternalMessage.java
index 40b529e..ba3c896 100644
--- a/utils/netty/src/main/java/org/onlab/netty/InternalMessage.java
+++ b/utils/netty/src/main/java/org/onlab/netty/InternalMessage.java
@@ -17,6 +17,10 @@
import java.io.IOException;
+import org.onlab.util.ByteArraySizeHashPrinter;
+
+import com.google.common.base.MoreObjects;
+
/**
* Internal message representation with additional attributes
* for supporting, synchronous request/reply behavior.
@@ -73,6 +77,15 @@
messagingService.sendAsync(sender, message);
}
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(this)
+ .add("id", id)
+ .add("type", type)
+ .add("sender", sender)
+ .add("payload", ByteArraySizeHashPrinter.of(payload))
+ .toString();
+ }
/**
* Builder for InternalMessages.