You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2014/03/26 10:51:58 UTC
[5/8] git commit: Autoscaler message delegator should have its own
message queue and also Autoscaler message receiver should have its own
message listener
Autoscaler message delegator should have its own message queue and also Autoscaler message receiver should have its own message listener
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/da730ec0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/da730ec0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/da730ec0
Branch: refs/heads/master
Commit: da730ec0edb6c185f95d58550e5c51665d67e115
Parents: 2ffbaa3
Author: Nirmal Fernando <ni...@apache.org>
Authored: Wed Mar 26 15:15:42 2014 +0530
Committer: Nirmal Fernando <ni...@apache.org>
Committed: Wed Mar 26 15:15:42 2014 +0530
----------------------------------------------------------------------
.../message/receiver/topology/AutoscalerTopologyReceiver.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da730ec0/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java
index d526717..44ace7d 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java
@@ -57,7 +57,7 @@ public class AutoscalerTopologyReceiver implements Runnable {
private boolean terminated;
public AutoscalerTopologyReceiver() {
- this.topologyReceiver = new TopologyReceiver(createMessageDelegator());
+ this.topologyReceiver = new TopologyReceiver(createMessageDelegator(), new TopologyEventMessageListener());
}
@Override
@@ -87,7 +87,7 @@ public class AutoscalerTopologyReceiver implements Runnable {
private TopologyEventMessageDelegator createMessageDelegator() {
TopologyMessageProcessorChain processorChain = createEventProcessorChain();
- return new TopologyEventMessageDelegator(processorChain);
+ return new TopologyEventMessageDelegator(processorChain, TopologyEventMessageQueue.getInstance());
}
private TopologyMessageProcessorChain createEventProcessorChain() {
@@ -127,6 +127,7 @@ public class AutoscalerTopologyReceiver implements Runnable {
@Override
protected void onEvent(Event event) {
try {
+ log.info("Event received: "+event);
ClusterCreatedEvent e = (ClusterCreatedEvent) event;
TopologyManager.acquireReadLock();
Service service = TopologyManager.getTopology().getService(e.getServiceName());