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 <[email protected]> Authored: Thu Dec 19 16:29:26 2013 +0530 Committer: Imesh Gunaratne <[email protected]> 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();
