diff options
Diffstat (limited to 'java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java')
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java b/java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java index d6ec8bd5de..d2f27da052 100644 --- a/java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java +++ b/java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java @@ -19,9 +19,6 @@ package org.apache.qpid.example.subscriber; import org.apache.log4j.BasicConfigurator; -import org.apache.qpid.example.shared.Statics; - -import java.util.Properties; /** * Allows you to simply start a monitored subscriber @@ -30,6 +27,10 @@ public class MonitoredSubscriptionWrapper { private static MonitoredSubscriber _subscriber; + /** + * Create a monitored subscriber and start it + * @param args - no params required + */ public static void main(String args[]) { //switch on logging @@ -37,15 +38,12 @@ public class MonitoredSubscriptionWrapper { _subscriber = new MonitoredSubscriber(); - //using system props but can replace with app appropriate config here - Properties props = System.getProperties(); - - //note that for failover should set -Dhost=host1:port1;host2:port2 - //Client will then failover in order i.e. connect to first host and failover to second and so on _subscriber.subscribe(); } - //Stop subscribing now ... + /** + * Stop subscribing now ... + */ public static void stop() { _subscriber.stop(); |