Updated Branches: refs/heads/master 0a24ca1b5 -> 193f8d367
Added un-subscribed tenant message processor and event listener to 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/193f8d36 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/193f8d36 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/193f8d36 Branch: refs/heads/master Commit: 193f8d367995073eedc602f0016e158d9f9dfc8f Parents: 0a24ca1 Author: Imesh Gunaratne <[email protected]> Authored: Sun Dec 8 01:07:52 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Sun Dec 8 01:07:52 2013 +0530 ---------------------------------------------------------------------- .../processor/tenant/TenantMessageProcessorChain.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/193f8d36/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 1d0c81c..2a2f9e2 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 @@ -22,10 +22,7 @@ package org.apache.stratos.messaging.message.processor.tenant; 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.TenantCreatedEventListener; -import org.apache.stratos.messaging.listener.tenant.TenantRemovedEventListener; -import org.apache.stratos.messaging.listener.tenant.TenantSubscribedEventListener; -import org.apache.stratos.messaging.listener.tenant.TenantUpdatedEventListener; +import org.apache.stratos.messaging.listener.tenant.*; import org.apache.stratos.messaging.listener.topology.CompleteTopologyEventListener; import org.apache.stratos.messaging.message.processor.MessageProcessorChain; @@ -40,6 +37,7 @@ public class TenantMessageProcessorChain extends MessageProcessorChain { private TenantUpdatedMessageProcessor tenantUpdatedMessageProcessor; private TenantRemovedMessageProcessor tenantRemovedMessageProcessor; private TenantSubscribedMessageProcessor tenantSubscribedMessageProcessor; + private TenantUnSubscribedMessageProcessor tenantUnSubscribedMessageProcessor; public void initialize() { // Add topology event processors @@ -58,6 +56,9 @@ public class TenantMessageProcessorChain extends MessageProcessorChain { tenantSubscribedMessageProcessor = new TenantSubscribedMessageProcessor(); add(tenantSubscribedMessageProcessor); + tenantUnSubscribedMessageProcessor = new TenantUnSubscribedMessageProcessor(); + add(tenantUnSubscribedMessageProcessor); + if (log.isDebugEnabled()) { log.debug("Tenant message processor chain initialized"); } @@ -74,7 +75,10 @@ public class TenantMessageProcessorChain extends MessageProcessorChain { tenantRemovedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof TenantSubscribedEventListener) { tenantSubscribedMessageProcessor.addEventListener(eventListener); - } else { + } else if (eventListener instanceof TenantUnSubscribedEventListener) { + tenantUnSubscribedMessageProcessor.addEventListener(eventListener); + } + else { throw new RuntimeException("Unknown event listener"); } }
