@ComponentProfile(summary="Listen for JMS messages on the specified queue", tag="consumer,jms", recommended=JmsConnection.class) public class PtpConsumer extends JmsConsumerImpl
JMS Queue implementation of AdaptrisMessageConsumer
In the adapter configuration file this class is aliased as jms-queue-consumer which is the preferred alternative to the fully qualified classname when building your configuration.
consumer
log
Constructor and Description |
---|
PtpConsumer() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
configuredEndpoint() |
protected javax.jms.MessageConsumer |
createConsumer() |
java.lang.String |
getQueue()
The JMS Queue
|
void |
setQueue(java.lang.String queue)
The JMS Queue
|
PtpConsumer |
withQueue(java.lang.String queue) |
close, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentLogger, currentSession, endpoint, getAcknowledgeMode, getCorrelationIdSource, getDestination, getMessageSelector, getMessageTranslator, init, isManagedTransaction, messageSelector, newThreadName, onMessage, prepare, rollbackTimeout, setAcknowledgeMode, setCorrelationIdSource, setDestination, setManagedTransaction, setMessageSelector, setMessageTranslator, 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 JmsConsumerImpl
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException, CoreException
createConsumer
in class JmsConsumerImpl
javax.jms.JMSException
CoreException
public PtpConsumer withQueue(java.lang.String queue)
public java.lang.String getQueue()
public void setQueue(java.lang.String queue)