@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
Constructor and Description |
---|
PasPollingConsumer() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
configuredEndpoint() |
protected javax.jms.MessageConsumer |
createConsumer() |
java.lang.String |
getSubscriptionId()
Returns the subscription ID to use.
|
java.lang.String |
getTopic()
The JMS Topic
|
void |
init()
Initialises the component.
|
void |
setSubscriptionId(java.lang.String s)
Sets the subscription ID to use.
|
void |
setTopic(java.lang.String topic)
The JMS Topic
|
PasPollingConsumer |
withTopic(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, 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 java.lang.String configuredEndpoint()
configuredEndpoint
in class JmsPollingConsumerImpl
public void init() throws CoreException
ComponentLifecycle
Component initialisation includes config verification, creation of connections etc.
init
in interface ComponentLifecycle
init
in class BaseJmsPollingConsumerImpl
CoreException
- wrapping any underlying Exception
sComponentLifecycle.init()
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
createConsumer
in class JmsPollingConsumerImpl
javax.jms.JMSException
public PasPollingConsumer withTopic(java.lang.String s)
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
public java.lang.String getTopic()
public void setTopic(java.lang.String topic)