You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2014/11/06 11:04:24 UTC
git commit: using the correct topic name in
ClusterStatusEventPublisher
Repository: stratos
Updated Branches:
refs/heads/docker-grouping-merge 48b6e3295 -> 827afe471
using the correct topic name in ClusterStatusEventPublisher
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/827afe47
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/827afe47
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/827afe47
Branch: refs/heads/docker-grouping-merge
Commit: 827afe47117e282795e2e5dd19271e3085bde351
Parents: 48b6e32
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Thu Nov 6 15:28:12 2014 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
Committed: Thu Nov 6 15:28:12 2014 +0530
----------------------------------------------------------------------
.../autoscaler/event/publisher/ClusterStatusEventPublisher.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/827afe47/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/ClusterStatusEventPublisher.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/ClusterStatusEventPublisher.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/ClusterStatusEventPublisher.java
index 22d6eb9..d8549f1 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/ClusterStatusEventPublisher.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/ClusterStatusEventPublisher.java
@@ -29,6 +29,7 @@ import org.apache.stratos.messaging.event.Event;
import org.apache.stratos.messaging.event.cluster.status.*;
import org.apache.stratos.messaging.message.receiver.topology.TopologyManager;
import org.apache.stratos.messaging.util.Constants;
+import org.apache.stratos.messaging.util.Util;
/**
* This will publish cluster status events to cluster-status topic
@@ -189,7 +190,8 @@ public class ClusterStatusEventPublisher {
public static void publishEvent(Event event) {
//publishing events to application status topic
- EventPublisher eventPublisher = EventPublisherPool.getPublisher(Constants.CLUSTER_STATUS_TOPIC);
+ String clusterStatusTopic = Util.getMessageTopicName(event);
+ EventPublisher eventPublisher = EventPublisherPool.getPublisher(clusterStatusTopic);
eventPublisher.publish(event);
}
}