Updated Branches: refs/heads/master c8d904cae -> a4c9f5a2c
Optimized imports and fixed variable names in tenant message processor chain Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/a4c9f5a2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/a4c9f5a2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/a4c9f5a2 Branch: refs/heads/master Commit: a4c9f5a2ceb11080c6a937387993ca634fdbc4b4 Parents: c8d904c Author: Imesh Gunaratne <[email protected]> Authored: Sun Dec 8 11:02:42 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Sun Dec 8 11:02:42 2013 +0530 ---------------------------------------------------------------------- .../processor/tenant/TenantMessageProcessorChain.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a4c9f5a2/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java index 2a2f9e2..d4c008e 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java @@ -23,7 +23,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.messaging.listener.EventListener; import org.apache.stratos.messaging.listener.tenant.*; -import org.apache.stratos.messaging.listener.topology.CompleteTopologyEventListener; import org.apache.stratos.messaging.message.processor.MessageProcessorChain; /** @@ -32,7 +31,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessorChain; public class TenantMessageProcessorChain extends MessageProcessorChain { private static final Log log = LogFactory.getLog(TenantMessageProcessorChain.class); - private CompleteTenantMessageProcessor completeTopologyMessageProcessor; + private CompleteTenantMessageProcessor completeTenantMessageProcessor; private TenantCreatedMessageProcessor tenantCreatedMessageProcessor; private TenantUpdatedMessageProcessor tenantUpdatedMessageProcessor; private TenantRemovedMessageProcessor tenantRemovedMessageProcessor; @@ -40,9 +39,9 @@ public class TenantMessageProcessorChain extends MessageProcessorChain { private TenantUnSubscribedMessageProcessor tenantUnSubscribedMessageProcessor; public void initialize() { - // Add topology event processors - completeTopologyMessageProcessor = new CompleteTenantMessageProcessor(); - add(completeTopologyMessageProcessor); + // Add tenant event processors + completeTenantMessageProcessor = new CompleteTenantMessageProcessor(); + add(completeTenantMessageProcessor); tenantCreatedMessageProcessor = new TenantCreatedMessageProcessor(); add(tenantCreatedMessageProcessor); @@ -65,8 +64,8 @@ public class TenantMessageProcessorChain extends MessageProcessorChain { } public void addEventListener(EventListener eventListener) { - if (eventListener instanceof CompleteTopologyEventListener) { - completeTopologyMessageProcessor.addEventListener(eventListener); + if (eventListener instanceof CompleteTenantEventListener) { + completeTenantMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof TenantCreatedEventListener) { tenantCreatedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof TenantUpdatedEventListener) {
