Package com.adaptris.core.jms.solace
Class ConsumerCreator
java.lang.Object
com.adaptris.core.jms.solace.ConsumerCreator
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionjavax.jms.MessageConsumer
createConsumer
(JmsDestination d, String selector, JmsActorConfig c, int maxRetries, int waitBetweenRetries) protected javax.jms.MessageConsumer
createConsumerWithRetry
(javax.jms.Session session, javax.jms.Destination destination, String selector, boolean noLocal, int maxRetries, int waitBetweenRetries) With Solace you can shut a queue down, which would mean it fails to startup.javax.jms.MessageConsumer
createQueueReceiver
(String queueName, String selector, JmsActorConfig c, int maxRetries, int waitBetweenRetries) If a Solace queue has been shutdown, we should wait for it to come back up before we continue.javax.jms.MessageConsumer
createTopicSubscriber
(String topicName, String selector, String subscriptionId, JmsActorConfig c)
-
Field Details
-
log
protected transient org.slf4j.Logger log
-
-
Constructor Details
-
ConsumerCreator
public ConsumerCreator()
-
-
Method Details
-
createQueueReceiver
public javax.jms.MessageConsumer createQueueReceiver(String queueName, String selector, JmsActorConfig c, int maxRetries, int waitBetweenRetries) throws javax.jms.JMSException If a Solace queue has been shutdown, we should wait for it to come back up before we continue.
- Throws:
javax.jms.JMSException
-
createConsumer
public javax.jms.MessageConsumer createConsumer(JmsDestination d, String selector, JmsActorConfig c, int maxRetries, int waitBetweenRetries) throws javax.jms.JMSException - Throws:
javax.jms.JMSException
-
createTopicSubscriber
public javax.jms.MessageConsumer createTopicSubscriber(String topicName, String selector, String subscriptionId, JmsActorConfig c) throws javax.jms.JMSException - Throws:
javax.jms.JMSException
-
createConsumerWithRetry
protected javax.jms.MessageConsumer createConsumerWithRetry(javax.jms.Session session, javax.jms.Destination destination, String selector, boolean noLocal, int maxRetries, int waitBetweenRetries) throws javax.jms.JMSException With Solace you can shut a queue down, which would mean it fails to startup. So here we will retry to create the consumer as many times as configured.- Parameters:
session
-destination
-selector
-noLocal
-maxRetries
-waitBetweenRetries
-- Returns:
- Throws:
javax.jms.JMSException
-