public abstract class QpidExceptionHandler extends Object implements javax.jms.ExceptionListener
Modifier and Type | Field and Description |
---|---|
protected AtomicBoolean |
_activated |
protected javax.jms.Connection |
_connection |
protected AtomicBoolean |
_deliveryActive |
protected javax.jms.Destination |
_destination |
protected javax.resource.spi.endpoint.MessageEndpointFactory |
_endpointFactory |
protected javax.jms.ConnectionFactory |
_factory |
protected AtomicBoolean |
_inFailure |
protected boolean |
_isDeliveryTransacted |
protected boolean |
_isTopic |
protected QpidResourceAdapter |
_ra |
protected QpidActivationSpec |
_spec |
static Method |
ONMESSAGE |
Modifier | Constructor and Description |
---|---|
protected |
QpidExceptionHandler(QpidResourceAdapter ra,
QpidActivationSpec spec,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
doesNotExist(Throwable failure)
Check to see if the failure represents a missing endpoint
|
void |
handleFailure(Throwable failure)
Handles any failure by trying to reconnect
|
protected boolean |
isXA() |
void |
onException(javax.jms.JMSException e) |
abstract void |
setup() |
protected void |
setupCF() |
protected void |
setupConnection() |
protected void |
setupDestination() |
abstract void |
start() |
abstract void |
stop() |
protected void |
teardown() |
public static final Method ONMESSAGE
protected final javax.resource.spi.endpoint.MessageEndpointFactory _endpointFactory
protected javax.jms.Connection _connection
protected javax.jms.ConnectionFactory _factory
protected javax.jms.Destination _destination
protected final QpidResourceAdapter _ra
protected final QpidActivationSpec _spec
protected boolean _isDeliveryTransacted
protected final AtomicBoolean _deliveryActive
protected boolean _isTopic
protected AtomicBoolean _inFailure
protected AtomicBoolean _activated
protected QpidExceptionHandler(QpidResourceAdapter ra, QpidActivationSpec spec, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory) throws javax.resource.ResourceException
javax.resource.ResourceException
public abstract void stop()
public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
public void handleFailure(Throwable failure)
failure
- the reason for the failureprotected boolean doesNotExist(Throwable failure)
failure
- The failure.protected boolean isXA()
protected void teardown()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.