@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
CONFIRMATION_ID_KEY
Constructor and Description |
---|
PtpConsumer() |
PtpConsumer(ConsumeDestination d) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.MessageConsumer |
createConsumer() |
close, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentLogger, currentSession, getAcknowledgeMode, getCorrelationIdSource, getMessageTranslator, init, isManagedTransaction, onMessage, prepare, rollbackTimeout, setAcknowledgeMode, setCorrelationIdSource, setManagedTransaction, setMessageTranslator, start, stop
changeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestination
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isTrackingEndpoint
public PtpConsumer()
public PtpConsumer(ConsumeDestination d)
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException, CoreException
createConsumer
in class JmsConsumerImpl
javax.jms.JMSException
CoreException