mstoeck3/autopsy-flatpak
1
0
Fork 0
mirror of https://github.com/overcuriousity/autopsy-flatpak.git synced 2025-07-17 10:17:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add close() calls for RemoteEventPublsiher JMS producer and consumer

Browse Source
This commit is contained in:
Richard Cordovano 2015-05-06 10:56:54 -04:00
parent d68ab15401
commit 51dcbed5ed
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java
View File

@ -49,6 +49,7 @@ final class RemoteEventPublisher {
private final Connection connection; private final Connection connection;
private final Session session; private final Session session;
private final MessageProducer producer; private final MessageProducer producer;
private MessageConsumer consumer;
private final MessageReceiver receiver; private final MessageReceiver receiver;
/** /**
@ -74,7 +75,7 @@ final class RemoteEventPublisher {
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(eventChannelName); Topic topic = session.createTopic(eventChannelName);
producer = session.createProducer(topic); 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(); receiver = new MessageReceiver();
consumer.setMessageListener(receiver); consumer.setMessageListener(receiver);
} catch (URISyntaxException | JMSException ex) { } catch (URISyntaxException | JMSException ex) {
@ -91,6 +92,12 @@ final class RemoteEventPublisher {
* connection. * connection.
*/ */
synchronized void stop() throws JMSException { synchronized void stop() throws JMSException {
if (null != producer) {
producer.close();
}
if (null != consumer) {
consumer.close();
}
if (null != session) { if (null != session) {
session.close(); session.close();
} }