Repository: stratos Updated Branches: refs/heads/master a8146cbb7 -> fda7afb86
fixing a wrong message processor Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/fda7afb8 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/fda7afb8 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/fda7afb8 Branch: refs/heads/master Commit: fda7afb86c6d70ca44795653850a8f6a74a0fca5 Parents: bfa253c Author: Isuru Haththotuwa <[email protected]> Authored: Mon Nov 10 17:23:40 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Mon Nov 10 17:24:02 2014 +0530 ---------------------------------------------------------------------- .../topology/TopologyMessageProcessorChain.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/fda7afb8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java index f51a521..5ba8d39 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java @@ -35,8 +35,8 @@ public class TopologyMessageProcessorChain extends MessageProcessorChain { private CompleteTopologyMessageProcessor completeTopologyMessageProcessor; private ServiceCreatedMessageProcessor serviceCreatedMessageProcessor; private ServiceRemovedMessageProcessor serviceRemovedMessageProcessor; - private ApplicationClustersCreatedMessageProcessor clustersCreatedMessageProcessor; - private ApplicationClustersRemovedMessageProcessor clustersRemovedMessageProcessor; + private ApplicationClustersCreatedMessageProcessor appClustersCreatedMessageProcessor; + private ApplicationClustersRemovedMessageProcessor appClustersRemovedMessageProcessor; private ClusterCreatedMessageProcessor clusterCreatedMessageProcessor; private ClusterResetMessageProcessor clusterResetMessageProcessor; private ClusterActivatedProcessor clusterActivatedProcessor; @@ -63,11 +63,11 @@ public class TopologyMessageProcessorChain extends MessageProcessorChain { serviceRemovedMessageProcessor = new ServiceRemovedMessageProcessor(); add(serviceRemovedMessageProcessor); - clustersCreatedMessageProcessor = new ApplicationClustersCreatedMessageProcessor(); - add(clustersCreatedMessageProcessor); + appClustersCreatedMessageProcessor = new ApplicationClustersCreatedMessageProcessor(); + add(appClustersCreatedMessageProcessor); - clustersRemovedMessageProcessor = new ApplicationClustersRemovedMessageProcessor(); - add(clusterRemovedMessageProcessor); + appClustersRemovedMessageProcessor = new ApplicationClustersRemovedMessageProcessor(); + add(appClustersRemovedMessageProcessor); clusterCreatedMessageProcessor = new ClusterCreatedMessageProcessor(); add(clusterCreatedMessageProcessor); @@ -122,9 +122,9 @@ public class TopologyMessageProcessorChain extends MessageProcessorChain { } else if (eventListener instanceof ClusterCreatedEventListener) { clusterCreatedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof ApplicationClustersCreatedEventListener) { - clustersCreatedMessageProcessor.addEventListener(eventListener); + appClustersCreatedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof ApplicationClustersRemovedEventListener) { - clustersRemovedMessageProcessor.addEventListener(eventListener); + appClustersRemovedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof ClusterActivatedEventListener) { clusterActivatedProcessor.addEventListener(eventListener); } else if (eventListener instanceof ClusterInActivateEventListener) {
