@ComponentProfile(summary="Pickup messages from a JMS broker (queue or topic) by actively polling it",
tag="consumer,jms",
recommended=NullConnection.class)
public class JmsPollingConsumer
extends JmsPollingConsumerImpl
JmsPollingConsumerImpl implementation that can target queues or topics via an
RFC6167 style destination.
This differs from the standard PtpPollingConsumer and PtpPollingConsumer in that
it supports a destination that is specified in RFC6167 style. For instance
jms:queue:myQueueName will consume from a queue called myQueueName and
jms:topic:myTopicName from a topic called myTopicName
If you specify a topic as the destination then you should also configure
JmsPollingConsumerImpl.setClientId(String). There are also some custom parameters that are used as part of the
URI defining the topic.
subscriptionId - which indicates the subscriptionId that should be used when
attaching a subscriber to a topic; jms:topic:MyTopicName?subscriptionId=myId would return
a JmsDestination.subscriptionId() of myId. This must be specified.noLocal - which corresponds to the
Session.createConsumer(javax.jms.Destination, String, boolean) noLocal setting.
This defaults to false, if not specified.For instance you could have the following destinations:
In the adapter configuration file this class is aliased as jms-poller which is the preferred alternative to the fully qualified classname when building your configuration.
AdaptrisPollingConsumer.LockOperatorlogCONFIRMATION_ID_KEY| Constructor and Description |
|---|
JmsPollingConsumer() |
JmsPollingConsumer(ConsumeDestination d) |
| Modifier and Type | Method and Description |
|---|---|
protected javax.jms.MessageConsumer |
createConsumer() |
additionalDebug, close, configuredAcknowledgeMode, configuredClientId, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, configuredPassword, configuredUserName, configuredVendorImplementation, consumeLocationKey, 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, setVendorImplementationcontinueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stopchangeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestinationcreateName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactoryclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdecode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactorygetUniqueIdcreateName, createQualifier, isTrackingEndpointpublic JmsPollingConsumer()
public JmsPollingConsumer(ConsumeDestination d)
protected javax.jms.MessageConsumer createConsumer()
throws javax.jms.JMSException
createConsumer in class JmsPollingConsumerImpljavax.jms.JMSException