From 51dcbed5edb62b9e1871cd68fba5404e7a9fe4a3 Mon Sep 17 00:00:00 2001
From: Richard Cordovano <rcordovano@basistech.com>
Date: Wed, 6 May 2015 10:56:54 -0400
Subject: [PATCH] Add close() calls for RemoteEventPublsiher JMS producer and
 consumer

---
 .../sleuthkit/autopsy/events/RemoteEventPublisher.java   | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java b/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java
index 470aa209b0..f449a8657a 100644
--- a/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java
+++ b/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java
@@ -49,6 +49,7 @@ final class RemoteEventPublisher {
     private final Connection connection;
     private final Session session;
     private final MessageProducer producer;
+    private MessageConsumer consumer;
     private final MessageReceiver receiver;
 
     /**
@@ -74,7 +75,7 @@ final class RemoteEventPublisher {
             session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
             Topic topic = session.createTopic(eventChannelName);
             producer = session.createProducer(topic);
-            MessageConsumer consumer = session.createConsumer(topic, "events = '" + ALL_MESSAGE_SELECTOR + "'", true);
+            consumer = session.createConsumer(topic, "events = '" + ALL_MESSAGE_SELECTOR + "'", true);
             receiver = new MessageReceiver();
             consumer.setMessageListener(receiver);
         } catch (URISyntaxException | JMSException ex) {
@@ -91,6 +92,12 @@ final class RemoteEventPublisher {
      * connection.
      */
     synchronized void stop() throws JMSException {
+        if (null != producer) {
+            producer.close();
+        }
+        if (null != consumer) {
+            consumer.close();
+        }        
         if (null != session) {
             session.close();
         }