You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ga...@apache.org on 2015/02/05 15:32:18 UTC
stratos git commit: Add application signup event listener
Repository: stratos
Updated Branches:
refs/heads/master adc3806be -> 16260d393
Add application signup event listener
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/16260d39
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/16260d39
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/16260d39
Branch: refs/heads/master
Commit: 16260d3939654c387b60a72bdf49f7c9bb28c5c2
Parents: adc3806
Author: Gayan Gunarathne <ga...@wso2.com>
Authored: Thu Feb 5 20:01:58 2015 +0530
Committer: Gayan Gunarathne <ga...@wso2.com>
Committed: Thu Feb 5 20:01:58 2015 +0530
----------------------------------------------------------------------
.../cartridgeagent/cartridgeagent/agent.py | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/16260d39/components/org.apache.stratos.python.cartridge.agent/cartridgeagent/cartridgeagent/agent.py
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.python.cartridge.agent/cartridgeagent/cartridgeagent/agent.py b/components/org.apache.stratos.python.cartridge.agent/cartridgeagent/cartridgeagent/agent.py
index 89cf052..8a7d177 100644
--- a/components/org.apache.stratos.python.cartridge.agent/cartridgeagent/cartridgeagent/agent.py
+++ b/components/org.apache.stratos.python.cartridge.agent/cartridgeagent/cartridgeagent/agent.py
@@ -80,6 +80,9 @@ class CartridgeAgent(threading.Thread):
#Start tenant event receiver thread
self.register_tenant_event_listeners()
+ #start application signup event listener
+ self.register_application_signup_event_listeners()
+
#wait for member initialized event
while not self.cartridge_agent_config.initialized:
self.log.debug("Waiting for cartridge agent to be initialized...")
@@ -285,11 +288,16 @@ class CartridgeAgent(threading.Thread):
self.__tenant_event_subscriber.register_handler("SubscriptionDomainsRemovedEvent", self.on_subscription_domain_removed)
self.__tenant_event_subscriber.register_handler("CompleteTenantEvent", self.on_complete_tenant)
self.__tenant_event_subscriber.register_handler("TenantSubscribedEvent", self.on_tenant_subscribed)
- self.__application_event_subscriber.register_handler("ApplicationSignUpRemovedEvent",self.on_application_signup_removed)
self.__tenant_event_subscriber.start()
self.log.info("Tenant event message receiver thread started")
+ def register_application_signup_event_listeners(self):
+ self.log.debug("Starting application signup event message receiver thread")
+ self.__application_event_subscriber.register_handler("ApplicationSignUpRemovedEvent",self.on_application_signup_removed)
+ self.__application_event_subscriber.start()
+ self.log.info("Application signup event message receiver thread started")
+
def on_subscription_domain_added(self, msg):
self.log.debug("Subscription domain added event received : %r" % msg.payload)
event_obj = SubscriptionDomainAddedEvent.create_from_json(msg.payload)