Changeset 373974a6fbcec5a328d77ddbfa850b1682f58b0b

Timestamp:

03/17/10 15:21:59 (3 years ago)

Author:

Theo Schlossnagle <jesus@omniti.com>

git-committer:

Theo Schlossnagle <jesus@omniti.com> 1268839319 +0000

git-parent:

[77c2f1d33af8c513f72b1dee14b5dd6d2104df06]

git-author:

Theo Schlossnagle <jesus@omniti.com> 1268839319 +0000

Message:

allow overriding the listner

Files:

• src/java/com/omniti/reconnoiter/broker/AMQBroker.java (modified) (3 diffs)
• src/java/com/omniti/reconnoiter/broker/RabbitBroker.java (modified) (4 diffs)

src/java/com/omniti/reconnoiter/broker/AMQBroker.java

@@ -8 +8 @@
-
-package com.omniti.reconnoiter.broker;
+
+import java.lang.reflect.Constructor;
-
-import javax.jms.Connection;
@@ -27 +29 @@
-  private String hostName;
-  private int portNumber;
+  private Class listenerClass;
+  private Constructor<UpdateListener> con;
+
+  @SuppressWarnings("unchecked")
-  public AMQBroker(StratconConfig config) {
-    this.hostName = config.getBrokerParameter("hostname", "127.0.0.1");
-    this.portNumber = Integer.parseInt(config.getBrokerParameter("port", "61613"));
+    String className = config.getBrokerParameter("listenerClass", "com.omniti.reconnoiter.broker.AMQListener");
+    try {
+      this.listenerClass = Class.forName(className);
+      this.con = this.listenerClass.getDeclaredConstructor(
+          new Class[] { EPServiceProvider.class, StratconQuery.class, String.class }
+      );
+    }
+    catch(java.lang.ClassNotFoundException e) {
+      throw new RuntimeException("Cannot find class: " + className);
+    }
+    catch(java.lang.NoSuchMethodException e) {
+      throw new RuntimeException("Cannot find constructor for class: " + className);
+    }
+
-  }
-
@@ -68 +88 @@
-  
-  public UpdateListener getListener(EPServiceProvider epService, StratconQuery sq) {
-
+
+
+
+
+
+
+
+
-  }
-}

src/java/com/omniti/reconnoiter/broker/RabbitBroker.java

@@ -10 +10 @@
-
-import java.io.IOException;
+import java.lang.reflect.Constructor;
-
-import com.espertech.esper.client.EPServiceProvider;
@@ -37 +38 @@
-  private String alertRoutingKey;
-  private String alertExchangeName;
+  private Class listenerClass;
+  private Constructor<UpdateListener> con;
-
+  @SuppressWarnings("unchecked") 
-  public RabbitBroker(StratconConfig config) {
-    this.userName = config.getBrokerParameter("username", "guest");
@@ -45 +49 @@
-    this.portNumber = Integer.parseInt(config.getBrokerParameter("port", "5672"));
-    
+    String className = config.getBrokerParameter("listenerClass", "com.omniti.reconnoiter.broker.RabbitListener");
+    try {
+      this.listenerClass = Class.forName(className);
+      this.con = this.listenerClass.getDeclaredConstructor(
+          new Class[] { EPServiceProvider.class, StratconQuery.class, Channel.class,
+                        String.class, String.class }
+      );
+    }
+    catch(java.lang.ClassNotFoundException e) {
+      throw new RuntimeException("Cannot find class: " + className);
+    }
+    catch(java.lang.NoSuchMethodException e) {
+      throw new RuntimeException("Cannot find constructor for class: " + className);
+    }
+
-    // This is a fanout exchange
-    this.exchangeName = config.getMQParameter("exchange", "noit.firehose");
@@ -118 +137 @@
-    }
-  }
-
+
-  public UpdateListener getListener(EPServiceProvider epService, StratconQuery sq) {
-
+
+
+
+
+
+
+
+
-  }
-}