Package com.adaptris.core.jms
Class PtpPollingConsumer
- java.lang.Object
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageConsumer
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,JmsActorConfig
,JmsConnectionConfig
,MessageEventGenerator
,StateManagedComponent
@ComponentProfile(summary="Pickup messages from a JMS Queue by actively polling for them", tag="consumer,jms", recommended=NullConnection.class) public class PtpPollingConsumer extends JmsPollingConsumerImpl
Queue implementation of
JmsPollingConsumerImpl
.In the adapter configuration file this class is aliased as jms-queue-poller which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumer
AdaptrisPollingConsumer.LockOperator
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description PtpPollingConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.String
configuredEndpoint()
protected javax.jms.MessageConsumer
createConsumer()
java.lang.String
getQueue()
The JMS Topicvoid
setQueue(java.lang.String queue)
The JMS TopicPtpPollingConsumer
withQueue(java.lang.String s)
-
Methods inherited from class com.adaptris.core.jms.JmsPollingConsumerImpl
additionalDebug, close, configuredClientId, configuredPassword, configuredUserName, configuredVendorImplementation, createConnectionFactory, createSession, currentLogger, getAdditionalDebug, getClientId, getPassword, getUserName, getVendorImplementation, newThreadName, prepareConsumer, processMessages, setAdditionalDebug, setClientId, setPassword, setUserName, setVendorImplementation
-
Methods inherited from class com.adaptris.core.jms.BaseJmsPollingConsumerImpl
closeMessageConsumer, closeSession, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentSession, doProcessMessage, getAcknowledgeMode, getCorrelationIdSource, getMessageSelector, getMessageTranslator, getReceiveTimeout, init, initConsumer, initSession, isManagedTransaction, messageConsumer, messageHandler, rollbackTimeout, setAcknowledgeMode, setCorrelationIdSource, setManagedTransaction, setMessageSelector, setMessageTranslator, setReceiveTimeout
-
Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stop
-
Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp
changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createName, createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
createConsumer
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
- Specified by:
createConsumer
in classJmsPollingConsumerImpl
- Throws:
javax.jms.JMSException
-
configuredEndpoint
protected java.lang.String configuredEndpoint()
- Specified by:
configuredEndpoint
in classJmsPollingConsumerImpl
-
withQueue
public PtpPollingConsumer withQueue(java.lang.String s)
-
getQueue
public java.lang.String getQueue()
The JMS Topic
-
setQueue
public void setQueue(java.lang.String queue)
The JMS Topic
-
-