You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2013/12/08 06:32:57 UTC
git commit: Optimized imports and fixed variable names in tenant
message processor chain
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 <im...@apache.org>
Authored: Sun Dec 8 11:02:42 2013 +0530
Committer: Imesh Gunaratne <im...@apache.org>
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) {