@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.
AdaptrisPollingConsumer.LockOperator
log
Constructor and Description |
---|
PtpPollingConsumer() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
configuredEndpoint() |
protected javax.jms.MessageConsumer |
createConsumer() |
java.lang.String |
getQueue()
The JMS Topic
|
void |
setQueue(java.lang.String queue)
The JMS Topic
|
PtpPollingConsumer |
withQueue(java.lang.String s) |
additionalDebug, close, configuredClientId, configuredPassword, configuredUserName, configuredVendorImplementation, createConnectionFactory, createSession, currentLogger, endpoint, getAdditionalDebug, getClientId, getDestination, getPassword, getUserName, getVendorImplementation, messageSelector, newThreadName, prepareConsumer, processMessages, setAdditionalDebug, setClientId, setDestination, setPassword, setUserName, setVendorImplementation
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
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stop
changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isTrackingEndpoint
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
createConsumer
in class JmsPollingConsumerImpl
javax.jms.JMSException
protected java.lang.String configuredEndpoint()
configuredEndpoint
in class JmsPollingConsumerImpl
public PtpPollingConsumer withQueue(java.lang.String s)
public java.lang.String getQueue()
public void setQueue(java.lang.String queue)