Repository: stratos Updated Branches: refs/heads/docker-grouping-merge 19fdf7a15 -> 757e33236
fixing class cast issue in the debug log Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/757e3323 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/757e3323 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/757e3323 Branch: refs/heads/docker-grouping-merge Commit: 757e332364517c4639287d701036f8a389e3eaf4 Parents: 19fdf7a Author: reka <[email protected]> Authored: Fri Nov 7 18:44:41 2014 +0530 Committer: reka <[email protected]> Committed: Fri Nov 7 18:44:41 2014 +0530 ---------------------------------------------------------------------- .../receiver/cluster/status/ClusterStatusEventMessageListener.java | 2 +- .../instance/status/InstanceStatusEventMessageListener.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/757e3323/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventMessageListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventMessageListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventMessageListener.java index 0ff4fb2..2c7e428 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventMessageListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventMessageListener.java @@ -77,7 +77,7 @@ class ClusterStatusEventMessageListener implements MqttCallback { if (log.isDebugEnabled()) { log.debug(String.format( "Instance notifier message received: %s", - ((TextMessage) message).getText())); + receivedMessage.getText())); } // Add received message to the queue messageQueue.add(receivedMessage); http://git-wip-us.apache.org/repos/asf/stratos/blob/757e3323/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventMessageListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventMessageListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventMessageListener.java index 9da3137..9b3d9c4 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventMessageListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventMessageListener.java @@ -77,7 +77,7 @@ class InstanceStatusEventMessageListener implements MqttCallback { if (log.isDebugEnabled()) { log.debug(String.format( "Instance notifier message received: %s", - ((TextMessage) message).getText())); + receivedMessage.getText())); } // Add received message to the queue messageQueue.add(receivedMessage);
