Class XAJmsPollingConsumer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageConsumerImp
-
- com.adaptris.core.AdaptrisPollingConsumer
-
- com.adaptris.xa.jms.XAJmsPollingConsumerImpl
-
- com.adaptris.xa.jms.XAJmsPollingConsumer
-
- All Implemented Interfaces:
AdaptrisComponent,AdaptrisMessageConsumer,AdaptrisMessageWorker,ComponentLifecycle,ComponentLifecycleExtension,JmsActorConfig,LicensedComponent,MessageEventGenerator,StateManagedComponent
@ComponentProfile(summary="Listen for JMS messages on the specified queue or topic", tag="consumer,jms", recommended=com.adaptris.xa.jms.XAJmsConnection.class) public class XAJmsPollingConsumer extends XAJmsPollingConsumerImplJMS Consumer implementation that can target queues or topics via an RFC6167 style destination.This differs from the standard
PtpConsumerandPasConsumerin that it supports a destination that is specified in RFC6167 style. For instancejms:queue:myQueueNamewill consume from a queue calledmyQueueNameandjms:topic:myTopicNamefrom a topic calledmyTopicNameWhile RFC6167 defines the ability to use jndi to lookup the (as part of the 'jndi' variant section); this is not supported. There is also support for
For instance you could have the following destinations:subscriptionIdwhich indicates the subscriptionId that should be used when attaching a subscriber to a topic;jms:topic:MyTopicName?subscriptionId=myIdwould return aJmsDestination.subscriptionId()ofmyId. If a subscription ID is not specified, then a durable subscriber is never created; specifying a subscription ID automatically means a durable subscriber.- jms:queue:MyQueueName
- jms:topic:MyTopicName
- jms:topic:MyTopicName?subscriptionId=mySubscriptionId
In the adapter configuration file this class is aliased as xa-jms-polling-consumer which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumer
AdaptrisPollingConsumer.LockOperator
-
-
Field Summary
-
Fields inherited from class com.adaptris.xa.jms.XAJmsPollingConsumerImpl
consumer
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description XAJmsPollingConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected javax.jms.MessageConsumercreateConsumer()-
Methods inherited from class com.adaptris.xa.jms.XAJmsPollingConsumerImpl
close, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentLogger, currentSession, endpoint, getConsumer, getCorrelationIdSource, getEndpoint, getMaxBatch, getMessageSelector, getMessageTranslator, handleXAException, init, isEnabled, isManagedTransaction, messageSelector, newThreadName, prepareConsumer, processMessages, rollbackTimeout, setConsumer, setCorrelationIdSource, setEndpoint, setMaxBatch, setMessageSelector, setMessageTranslator, start, stop, withEndpoint
-
Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages
-
Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp
changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createName, createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
createConsumer
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException, CoreException- Specified by:
createConsumerin classXAJmsPollingConsumerImpl- Throws:
javax.jms.JMSExceptionCoreException
-
-