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);