fixing topic name issue when publishing to instance notifier topic
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/21e3d224 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/21e3d224 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/21e3d224 Branch: refs/heads/master Commit: 21e3d2241c424a1501a753658454981b01cd4c75 Parents: 728ffe9 Author: reka <[email protected]> Authored: Sat Nov 8 23:54:57 2014 +0530 Committer: reka <[email protected]> Committed: Sun Nov 9 12:02:21 2014 +0530 ---------------------------------------------------------------------- .../event/publisher/InstanceNotificationPublisher.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/21e3d224/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/InstanceNotificationPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/InstanceNotificationPublisher.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/InstanceNotificationPublisher.java index 19c5e17..0163d23 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/InstanceNotificationPublisher.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/publisher/InstanceNotificationPublisher.java @@ -27,12 +27,16 @@ import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.instance.notifier.InstanceCleanupClusterEvent; import org.apache.stratos.messaging.event.instance.notifier.InstanceCleanupMemberEvent; import org.apache.stratos.messaging.util.Constants; +import org.apache.stratos.messaging.util.Util; public class InstanceNotificationPublisher { private static final Log log = LogFactory.getLog(InstanceNotificationPublisher.class); private static void publish(Event event) { - EventPublisher instanceNotifyingEvent = EventPublisherPool.getPublisher(Constants.INSTANCE_NOTIFIER_TOPIC); + String topic = Util.getMessageTopicName(event); + + EventPublisher instanceNotifyingEvent = EventPublisherPool. + getPublisher(topic); instanceNotifyingEvent.publish(event); }
