org.apache.qpid.ra.inflow

Class QpidMessageHandler

java.lang.Object

org.apache.qpid.ra.inflow.QpidExceptionHandler

org.apache.qpid.ra.inflow.QpidMessageHandler

All Implemented Interfaces:

javax.jms.ExceptionListener, javax.jms.MessageListener

public class QpidMessageHandler
extends QpidExceptionHandler
implements javax.jms.MessageListener

The message handler

Field Summary

Fields inherited from class org.apache.qpid.ra.inflow.QpidExceptionHandler

_activated, _connection, _deliveryActive, _destination, _endpointFactory, _factory, _inFailure, _isDeliveryTransacted, _isTopic, _ra, _spec, ONMESSAGE

Constructor Summary

Constructors

Constructor and Description
QpidMessageHandler(QpidResourceAdapter ra, QpidActivationSpec spec, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, TransactionManager tm)
QpidMessageHandler(QpidResourceAdapter ra, QpidActivationSpec spec, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, TransactionManager tm, javax.jms.Connection connection)

Method Summary

Modifier and Type	Method and Description
void	onMessage(javax.jms.Message message)
void	setup()
void	start()
void	stop()
void	teardown() Stop the handler

Methods inherited from class org.apache.qpid.ra.inflow.QpidExceptionHandler

doesNotExist, handleFailure, isXA, onException, setupCF, setupConnection, setupDestination

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QpidMessageHandler

public QpidMessageHandler(QpidResourceAdapter ra,
                          QpidActivationSpec spec,
                          javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
                          TransactionManager tm,
                          javax.jms.Connection connection)
                   throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

QpidMessageHandler

public QpidMessageHandler(QpidResourceAdapter ra,
                          QpidActivationSpec spec,
                          javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
                          TransactionManager tm)
                   throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

Method Detail

setup

public void setup()
           throws Exception

Specified by:

setup in class QpidExceptionHandler

Throws:

Exception

teardown

public void teardown()

Stop the handler

Overrides:

teardown in class QpidExceptionHandler

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

start

public void start()
           throws Exception

Specified by:

start in class QpidExceptionHandler

Throws:

Exception

stop

public void stop()

Specified by:

stop in class QpidExceptionHandler