@ComponentProfile(summary="Pickup messages from a JMS Topic by actively polling for them", tag="consumer,jms", recommended=NullConnection.class) public class PasPollingConsumer extends JmsPollingConsumerImpl
PAS implementation of JmsPollingConsumer
. The consumer created by this class is always durable and thus requires the
clientID and subscriptionId to be set. It is up to the user to ensure that these are set such that this consumer is uniquely
identified in the context of the broker's other consumers.
In the adapter configuration file this class is aliased as jms-topic-poller which is the preferred alternative to the fully qualified classname when building your configuration.
AdaptrisPollingConsumer.LockOperator
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
PasPollingConsumer()
Creates a new instance.
|
PasPollingConsumer(ConsumeDestination d) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.MessageConsumer |
createConsumer() |
java.lang.String |
getSubscriptionId()
Returns the subscription ID to use.
|
void |
init()
Initialises the component.
|
void |
setSubscriptionId(java.lang.String s)
Sets the subscription ID to use.
|
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, 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 PasPollingConsumer()
Creates a new instance.
public PasPollingConsumer(ConsumeDestination d)
public void init() throws CoreException
ComponentLifecycle
Component initialisation includes config verification, creation of connections etc.
init
in interface ComponentLifecycle
init
in class JmsPollingConsumerImpl
CoreException
- wrapping any underlying Exception
sComponentLifecycle.init()
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
createConsumer
in class JmsPollingConsumerImpl
javax.jms.JMSException
public java.lang.String getSubscriptionId()
Returns the subscription ID to use.
public void setSubscriptionId(java.lang.String s)
Sets the subscription ID to use. This, in combination with the clientId should uniquely identify this subscription in the context of the broker.
s
- the subscription ID to useJmsPollingConsumerImpl