Allow the abstract text publisher to be configured to publish to many…

… different sources.

symmetric/src/main/java/org/jumpmind/symmetric/ext/AbstractJmsPublisher.java → symmetric/src/main/java/org/jumpmind/symmetric/ext/AbstractTextPublisher.java

@@ -29,19 +29,18 @@
 import org.jumpmind.symmetric.load.IDataLoaderContext;
 import org.jumpmind.symmetric.load.IDataLoaderFilter;
 import org.jumpmind.symmetric.model.IncomingBatchHistory;
-import org.springframework.jms.core.JmsTemplate;
 
 /**
  * An abstract convenience class meant to be implemented by classes that need to
- * publish JMS messages
+ * publish text messages
  */
-abstract public class AbstractJmsPublisher implements IDataLoaderFilter, IBatchListener {
+abstract public class AbstractTextPublisher implements IDataLoaderFilter, IBatchListener {
 
-    private static final Log logger = LogFactory.getLog(AbstractJmsPublisher.class);
+    private static final Log logger = LogFactory.getLog(AbstractTextPublisher.class);
 
     private static final String msg_CACHE = "msg_CACHE";
 
-    protected JmsTemplate jmsTemplate;
+    protected IPublisher publisher;
 
     private boolean loadDataInTargetDatabase = true;
 
@@ -114,9 +113,9 @@ private void finalizeAndPublish(IDataLoaderContext ctx) {
             msg.append(addTextFooter(ctx));
 
             if (logger.isDebugEnabled()) {
-                logger.debug("Sending Text to JMS -> " + msg);
+                logger.debug("publishing text message -> " + msg);
             }
-            jmsTemplate.convertAndSend(msg.toString());
+            publisher.publish(msg.toString());
         }
     }
 
@@ -127,10 +126,6 @@ public void batchComplete(IDataLoader loader, IncomingBatchHistory hist) {
         }
     }
 
-    public void setJmsTemplate(JmsTemplate jmsTemplate) {
-        this.jmsTemplate = jmsTemplate;
-    }
-
     public void setLoadDataInTargetDatabase(boolean loadDataInTargetDatabase) {
         this.loadDataInTargetDatabase = loadDataInTargetDatabase;
     }
@@ -139,4 +134,8 @@ public void setTableList(Set<String> tableList) {
         this.tableList = tableList;
     }
 
+    public void setPublisher(IPublisher publisher) {
+        this.publisher = publisher;
+    }
+
 }

symmetric/src/main/java/org/jumpmind/symmetric/ext/IPublisher.java

@@ -0,0 +1,5 @@
+package org.jumpmind.symmetric.ext;
+
+public interface IPublisher {
+    public void publish(String text);
+}

symmetric/src/main/java/org/jumpmind/symmetric/ext/SimpleJmsPublisher.java

@@ -0,0 +1,17 @@
+package org.jumpmind.symmetric.ext;
+
+import org.springframework.jms.core.JmsTemplate;
+
+public class SimpleJmsPublisher implements IPublisher {
+
+    JmsTemplate jmsTemplate;
+
+    public void publish(String text) {
+       jmsTemplate.convertAndSend(text);
+    }
+
+    public void setJmsTemplate(JmsTemplate jmsTemplate) {
+        this.jmsTemplate = jmsTemplate;
+    }
+
+}