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/19 11:59:49 UTC
[1/2] git commit: Added isSubscribed() method to instance notifier
event message receiver
Updated Branches:
refs/heads/master 9d45314eb -> 195dc22b0
Added isSubscribed() method to instance notifier event message receiver
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/c70feaeb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/c70feaeb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/c70feaeb
Branch: refs/heads/master
Commit: c70feaeb0756b8f75c10be9d4988727e407221ae
Parents: b6dbaf6
Author: Imesh Gunaratne <im...@apache.org>
Authored: Thu Dec 19 16:29:26 2013 +0530
Committer: Imesh Gunaratne <im...@apache.org>
Committed: Thu Dec 19 16:29:26 2013 +0530
----------------------------------------------------------------------
.../event/instance/notifier/ArtifactUpdatedEvent.java | 6 ++++++
.../notifier/InstanceNotifierEventMessageReceiver.java | 4 ++++
2 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/c70feaeb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/instance/notifier/ArtifactUpdatedEvent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/instance/notifier/ArtifactUpdatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/instance/notifier/ArtifactUpdatedEvent.java
index 80f6817..fe0240d 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/instance/notifier/ArtifactUpdatedEvent.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/instance/notifier/ArtifactUpdatedEvent.java
@@ -81,4 +81,10 @@ public class ArtifactUpdatedEvent extends InstanceNotifierEvent implements Seria
public void setTenantId(String tenantId) {
this.tenantId = tenantId;
}
+
+ @Override
+ public String toString() {
+ return String.format("[cluster] %s [repo-url] %s [repo-username] %s [tenant] %s",
+ getClusterId(), getRepoURL(), getRepoUserName(), getTenantId());
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/c70feaeb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java
index 98040d8..2b803d3 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java
@@ -69,6 +69,10 @@ public class InstanceNotifierEventMessageReceiver implements Runnable {
}
}
+ public boolean isSubscribed() {
+ return ((topicSubscriber != null) && (topicSubscriber.isSubscribed()));
+ }
+
public void terminate() {
topicSubscriber.terminate();
messageDelegator.terminate();
[2/2] git commit: Merge remote-tracking branch 'origin/master'
Posted by im...@apache.org.
Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/195dc22b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/195dc22b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/195dc22b
Branch: refs/heads/master
Commit: 195dc22b00943823d5ad303dca39eac022c114f8
Parents: c70feae 9d45314
Author: Imesh Gunaratne <im...@apache.org>
Authored: Thu Dec 19 16:29:41 2013 +0530
Committer: Imesh Gunaratne <im...@apache.org>
Committed: Thu Dec 19 16:29:41 2013 +0530
----------------------------------------------------------------------
.../controller/topology/TopologyEventMessageDelegator.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------