summaryrefslogtreecommitdiff
path: root/java/client/src/test/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java
diff options
context:
space:
mode:
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.java16
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();