Package com.adaptris.core.jms

Class PtpPollingConsumer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.core.AdaptrisPollingConsumer

com.adaptris.core.jms.BaseJmsPollingConsumerImpl

com.adaptris.core.jms.JmsPollingConsumerImpl

com.adaptris.core.jms.PtpPollingConsumer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, JmsActorConfig, JmsConnectionConfig, MessageEventGenerator, StateManagedComponent

@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.

Nested Class Summary

Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumer

AdaptrisPollingConsumer.LockOperator

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
PtpPollingConsumer()

Method Summary

Modifier and Type	Method	Description
protected java.lang.String	configuredEndpoint()
protected javax.jms.MessageConsumer	createConsumer()
java.lang.String	getQueue()	The JMS Topic
void	setQueue(java.lang.String queue)	The JMS Topic
PtpPollingConsumer	withQueue(java.lang.String s)

Methods inherited from class com.adaptris.core.jms.JmsPollingConsumerImpl

additionalDebug, close, configuredClientId, configuredPassword, configuredUserName, configuredVendorImplementation, createConnectionFactory, createSession, currentLogger, getAdditionalDebug, getClientId, getPassword, getUserName, getVendorImplementation, newThreadName, prepareConsumer, processMessages, setAdditionalDebug, setClientId, setPassword, setUserName, setVendorImplementation

Methods inherited from class com.adaptris.core.jms.BaseJmsPollingConsumerImpl

closeMessageConsumer, closeSession, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentSession, doProcessMessage, getAcknowledgeMode, getCorrelationIdSource, getMessageSelector, getMessageTranslator, getReceiveTimeout, init, initConsumer, initSession, isManagedTransaction, messageConsumer, messageHandler, rollbackTimeout, setAcknowledgeMode, setCorrelationIdSource, setManagedTransaction, setMessageSelector, setMessageTranslator, setReceiveTimeout

Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer

continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stop

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

Constructor Detail

PtpPollingConsumer

public PtpPollingConsumer()

Method Detail

createConsumer

protected javax.jms.MessageConsumer createConsumer()
                                            throws javax.jms.JMSException

Specified by:

createConsumer in class JmsPollingConsumerImpl

Throws:

javax.jms.JMSException

configuredEndpoint

protected java.lang.String configuredEndpoint()

Specified by:

configuredEndpoint in class JmsPollingConsumerImpl

withQueue

public PtpPollingConsumer withQueue(java.lang.String s)

getQueue

public java.lang.String getQueue()

The JMS Topic

setQueue

public void setQueue(java.lang.String queue)

The JMS Topic