Enhancements for the aai-common library

[aai/aai-common.git] / aai-core / src / main / java / org / onap / aai / dmaap / AAIDmaapEventJMSProducer.java

diff --git a/aai-core/src/main/java/org/onap/aai/dmaap/AAIDmaapEventJMSProducer.java b/aai-core/src/main/java/org/onap/aai/dmaap/AAIDmaapEventJMSProducer.java
index 4036b90..eb0d165 100644 (file)
--- a/aai-core/src/main/java/org/onap/aai/dmaap/AAIDmaapEventJMSProducer.java
+++ b/aai-core/src/main/java/org/onap/aai/dmaap/AAIDmaapEventJMSProducer.java
@@ -50,4 +50,12 @@ public class AAIDmaapEventJMSProducer implements MessageProducer {
             ccf.destroy();
         }
     }
+
+    public void sendMessageToDefaultDestination(String msg) {
+        if (jmsTemplate != null) {
+            jmsTemplate.convertAndSend(msg);
+            CachingConnectionFactory ccf = (CachingConnectionFactory) this.jmsTemplate.getConnectionFactory();
+            ccf.destroy();
+        }
+    }
 }