Package com.adaptris.core.jms

Class PtpConsumer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.core.jms.JmsConsumerImpl

com.adaptris.core.jms.PtpConsumer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, JmsActorConfig, MessageEventGenerator, StateManagedComponent, javax.jms.MessageListener

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

Field Summary

Fields inherited from class com.adaptris.core.jms.JmsConsumerImpl

consumer

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
PtpConsumer()

Method Summary

Modifier and Type	Method	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)

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

close, configuredAcknowledgeMode, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, consumeLocationKey, currentLogger, currentSession, getAcknowledgeMode, getCorrelationIdSource, getMessageSelector, getMessageTranslator, init, isManagedTransaction, newThreadName, onMessage, prepare, rollbackTimeout, setAcknowledgeMode, setCorrelationIdSource, setManagedTransaction, setMessageSelector, setMessageTranslator, 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

PtpConsumer

public PtpConsumer()

Method Detail

configuredEndpoint

protected java.lang.String configuredEndpoint()

Specified by:

configuredEndpoint in class JmsConsumerImpl

createConsumer

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

Specified by:

createConsumer in class JmsConsumerImpl

Throws:

javax.jms.JMSException

CoreException

withQueue

public PtpConsumer withQueue(java.lang.String queue)

getQueue

public java.lang.String getQueue()

The JMS Queue

setQueue

public void setQueue(java.lang.String queue)

The JMS Queue