Logging improvements.
Change-Id: I79b9ff16a0000e4bd72022f02baef5c779ea1b48
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 2df3e7a..b27e009 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
@@ -150,7 +150,7 @@
messagingService.sendAsync(nodeEp, subject.value(), payload);
return true;
} catch (IOException e) {
- log.trace("Failed to send cluster message to nodeId: " + toNodeId, e);
+ log.debug("Failed to send cluster message to nodeId: " + toNodeId, e);
throw e;
}
}
@@ -179,6 +179,7 @@
}
@Override
+ @Deprecated
public void addSubscriber(MessageSubject subject,
ClusterMessageHandler subscriber) {
messagingService.registerHandler(subject.value(), new InternalClusterMessageHandler(subscriber));
@@ -210,13 +211,13 @@
try {
clusterMessage = SERIALIZER.decode(message.payload());
} catch (Exception e) {
- log.error("Failed decoding ClusterMessage {}", message, e);
+ log.error("Failed decoding {}", message, e);
throw e;
}
try {
handler.handle(new InternalClusterMessage(clusterMessage, message));
} catch (Exception e) {
- log.error("Exception caught handling {}", clusterMessage, e);
+ log.trace("Failed handling {}", clusterMessage, e);
throw e;
}
}