@ComponentProfile(summary="Listen for JMS messages on the specified topic", tag="consumer,jms", recommended=JmsConnection.class) public class PasConsumer extends JmsConsumerImpl
JMS Publish-and-subscribe implementation of AdaptrisMessageConsumer
.
In the adapter configuration file this class is aliased as jms-topic-consumer which is the preferred alternative to the fully qualified classname when building your configuration.
consumer
log
Constructor and Description |
---|
PasConsumer() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
configuredEndpoint() |
protected javax.jms.MessageConsumer |
createConsumer() |
java.lang.Boolean |
getDurable()
Deprecated.
|
java.lang.String |
getSubscriptionId()
Our subscription ID.
|
java.lang.String |
getTopic()
The JMS Topic
|
void |
prepare()
Prepare for initialisation.
|
void |
setDurable(java.lang.Boolean durable)
Deprecated.
|
void |
setSubscriptionId(java.lang.String subscriptionId)
Our subscription ID.
|
void |
setTopic(java.lang.String topic)
The JMS Topic
|
protected java.lang.String |
subscriptionId() |
PasConsumer |
withTopic(java.lang.String t) |
close, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentLogger, currentSession, endpoint, getAcknowledgeMode, getCorrelationIdSource, getDestination, getMessageSelector, getMessageTranslator, init, isManagedTransaction, messageSelector, newThreadName, onMessage, 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 subscriptionId()
public void prepare() throws CoreException
ComponentLifecycleExtension
prepare
in interface ComponentLifecycleExtension
prepare
in class JmsConsumerImpl
CoreException
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 PasConsumer withTopic(java.lang.String t)
@Deprecated public java.lang.Boolean getDurable()
@Deprecated public void setDurable(java.lang.Boolean durable)
public java.lang.String getSubscriptionId()
Sets the subscription ID to use for durable subscriptions. This must remain constant for the same durable subscription to be accessed each time messages are consumed.
public void setSubscriptionId(java.lang.String subscriptionId)
Sets the subscription ID to use for durable subscriptions. This must remain constant for the same durable subscription to be accessed each time messages are consumed.
public java.lang.String getTopic()
public void setTopic(java.lang.String topic)