Set JMS Producer for RemoteEventPublisher to non-peristent delivery

This commit is contained in:
Richard Cordovano 2015-05-06 11:16:54 -04:00
parent ca02628230
commit edc9d3e48e

View File

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