1 files changed, 42 insertions, 0 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java b/java/client/src/test/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java
new file mode 100644
index 0000000000..bc0363be2a
--- /dev/null
+++ b/java/client/src/test/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java
@@ -0,0 +1,42 @@
+package org.apache.qpid.example.subscriber;
+
+import org.apache.qpid.example.shared.Statics;
+
+import java.util.Properties;
+
+import org.apache.log4j.BasicConfigurator;
+
+/**
+ * Allows you to simply start a subscriber
+ * Author: Marnie McCormack
+ * Date: 08-Aug-2006
+ * Time: 12:05:52
+ * Copyright JPMorgan Chase 2006
+ */
+public class SubscriptionWrapper {
+
+    private static Subscriber _subscriber;
+
+    public static void main(String args[])
+    {
+        //switch on logging
+        BasicConfigurator.configure();
+        
+         _subscriber = new Subscriber();
+
+        //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(props.getProperty(Statics.HOST_PROPERTY),
+                                props.getProperty(Statics.USER_PROPERTY), props.getProperty(Statics.PWD_PROPERTY),
+                                props.getProperty(Statics.VIRTUAL_PATH_PROPERTY), props.getProperty(Statics.QUEUE_PROPERTY));
+    }
+
+    //Stop subscribing now ...
+    public static void stop()
+    {
+        _subscriber.stop();
+    }
+}