From edc9d3e48eab5d2d97e5b483d24d49c6e28f8520 Mon Sep 17 00:00:00 2001 From: Richard Cordovano Date: Wed, 6 May 2015 11:16:54 -0400 Subject: [PATCH] Set JMS Producer for RemoteEventPublisher to non-peristent delivery --- Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java b/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java index f449a8657a..ff144b39c6 100644 --- a/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java +++ b/Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java @@ -22,6 +22,7 @@ import java.net.URISyntaxException; import java.util.logging.Level; import javax.annotation.concurrent.Immutable; import javax.jms.Connection; +import javax.jms.DeliveryMode; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; @@ -75,6 +76,7 @@ final class RemoteEventPublisher { session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTopic(eventChannelName); producer = session.createProducer(topic); + producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); consumer = session.createConsumer(topic, "events = '" + ALL_MESSAGE_SELECTOR + "'", true); receiver = new MessageReceiver(); consumer.setMessageListener(receiver);