Repository: stratos Updated Branches: refs/heads/master 9c0ee56c8 -> 4d7491f15
Improved the log and move the log. Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/4d7491f1 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/4d7491f1 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/4d7491f1 Branch: refs/heads/master Commit: 4d7491f1586e8ab5ea4b5d09d47e92c8162de2c1 Parents: 9c0ee56 Author: Nirmal Fernando <[email protected]> Authored: Wed Oct 1 09:20:56 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Wed Oct 1 09:20:56 2014 +0530 ---------------------------------------------------------------------- .../status/InstanceStatusEventMessageListener.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/4d7491f1/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topic/instance/status/InstanceStatusEventMessageListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topic/instance/status/InstanceStatusEventMessageListener.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topic/instance/status/InstanceStatusEventMessageListener.java index b3e4a35..8dbddef 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topic/instance/status/InstanceStatusEventMessageListener.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topic/instance/status/InstanceStatusEventMessageListener.java @@ -60,18 +60,17 @@ public class InstanceStatusEventMessageListener implements MqttCallback { TextMessage receivedMessage = new ActiveMQTextMessage(); - receivedMessage.setText(new String(message.getPayload())); - receivedMessage.setStringProperty(Constants.EVENT_CLASS_NAME, - ORG_APACHE_STRATOS_MESSAGING_EVENT - .concat(arg0.replace("/", - "."))); - try { if (log.isDebugEnabled()) { log.debug(String.format( "Instance notifier message received: %s", - ((TextMessage) message).getText())); + receivedMessage.getText())); } + receivedMessage.setText(new String(message.getPayload())); + receivedMessage.setStringProperty(Constants.EVENT_CLASS_NAME, + ORG_APACHE_STRATOS_MESSAGING_EVENT.concat(arg0.replace( + "/", "."))); + // Add received message to the queue InstanceStatusEventMessageQueue.getInstance().add( receivedMessage);
