Package com.adaptris.core.jms.solace

Class ConsumerCreator

java.lang.Object

com.adaptris.core.jms.solace.ConsumerCreator

public class ConsumerCreator
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
ConsumerCreator()

Method Summary

Modifier and Type	Method	Description
javax.jms.MessageConsumer	createConsumer(JmsDestination d, java.lang.String selector, JmsActorConfig c, int maxRetries, int waitBetweenRetries)
protected javax.jms.MessageConsumer	createConsumerWithRetry(javax.jms.Session session, javax.jms.Destination destination, java.lang.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(java.lang.String queueName, java.lang.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(java.lang.String topicName, java.lang.String selector, java.lang.String subscriptionId, JmsActorConfig c)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

ConsumerCreator

public ConsumerCreator()

Method Detail

createQueueReceiver

public javax.jms.MessageConsumer createQueueReceiver(java.lang.String queueName,
                                                     java.lang.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,
                                                java.lang.String selector,
                                                JmsActorConfig c,
                                                int maxRetries,
                                                int waitBetweenRetries)
                                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTopicSubscriber

public javax.jms.MessageConsumer createTopicSubscriber(java.lang.String topicName,
                                                       java.lang.String selector,
                                                       java.lang.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,
                                                            java.lang.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