@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
CONFIRMATION_ID_KEY
Constructor and Description |
---|
PtpPollingConsumer() |
PtpPollingConsumer(ConsumeDestination d) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.MessageConsumer |
createConsumer() |
additionalDebug, close, configuredAcknowledgeMode, configuredClientId, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, configuredPassword, configuredUserName, configuredVendorImplementation, consumeLocationKey, createConnection, createConnectionFactory, createSession, currentLogger, currentSession, getAcknowledgeMode, getAdditionalDebug, getClientId, getCorrelationIdSource, getMessageTranslator, getPassword, getReceiveTimeout, getUserName, getVendorImplementation, init, isManagedTransaction, prepareConsumer, processMessages, rollbackTimeout, setAcknowledgeMode, setAdditionalDebug, setClientId, setCorrelationIdSource, setManagedTransaction, setMessageTranslator, setPassword, setReceiveTimeout, setUserName, setVendorImplementation
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stop
changeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestination
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isTrackingEndpoint
public PtpPollingConsumer()
public PtpPollingConsumer(ConsumeDestination d)
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
createConsumer
in class JmsPollingConsumerImpl
javax.jms.JMSException