org.apache.commons.messenger

Class XAMessenger

java.lang.Object

org.apache.commons.messenger.MessengerSupport

org.apache.commons.messenger.DefaultMessenger

org.apache.commons.messenger.XAMessenger

All Implemented Interfaces:

Messenger, XACapable

public class XAMessenger
extends DefaultMessenger
implements XACapable

XAMessenger is a default implementation of Messenger which can also support XA transactions by enlisting and delisting XAResources. This is implemented as a seperate Messenger implementation to avoid the core Messenger having a dependency on JTA. .

Version:

$Revision: 1.3 $

Author:

James Strachan

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.commons.logging.Log	log Logger

Constructor Summary

Constructors

Constructor and Description
XAMessenger()

Method Summary

Methods

Modifier and Type	Method and Description
void	delistResources(javax.transaction.Transaction transaction, int flag) This method is called to delist any XA resources the given object has previously enlisted to this XA transaction.
void	enlistResources(javax.transaction.Transaction transaction) This method is called to enlist any XA resources the given object has to be part of the XA transaction.
protected javax.transaction.xa.XAResource	getXAResource()

Methods inherited from class org.apache.commons.messenger.DefaultMessenger

borrowMessengerSession, call, call, clearReplyToDestination, close, createMessengerSession, createServerSessionPool, createSessionFactory, getAsyncSession, getConnection, getMessengerSession, getQueue, getReplyToConsumer, getReplyToDestination, getSession, getSessionFactory, getTopic, isTopic, isTopic, returnMessengerSession, setSessionFactory

Methods inherited from class org.apache.commons.messenger.MessengerSupport

addListener, addListener, borrowMessageConsumer, borrowMessageConsumer, commit, createBrowser, createBrowser, createBytesMessage, createConnectionConsumer, createConnectionConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createMessageConsumer, createMessageConsumer, createMessageProducer, createObjectMessage, createObjectMessage, createStreamMessage, createTemporaryDestination, createTextMessage, createTextMessage, getDeliveryMode, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getDurableName, getName, getPriority, getTimeToLive, isCacheProducers, isCacheRequestors, isDurable, isJndiDestinations, isNoLocal, receive, receive, receive, receive, receiveNoWait, receiveNoWait, removeListener, removeListener, returnMessageConsumer, rollback, run, send, send, setCacheProducers, setCacheRequestors, setDeliveryMode, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setDurable, setDurableName, setJndiDestinations, setName, setNoLocal, setPersistentDelivery, setPriority, setTimeToLive, toString

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.apache.commons.logging.Log log

Logger

Constructor Detail

XAMessenger

public XAMessenger()

Method Detail

enlistResources

public void enlistResources(javax.transaction.Transaction transaction)
                     throws java.lang.Exception

Description copied from interface: XACapable

This method is called to enlist any XA resources the given object has to be part of the XA transaction.

Specified by:

enlistResources in interface XACapable

Parameters:

transaction - the transaction to enlist to

Throws:

java.lang.Exception

delistResources

public void delistResources(javax.transaction.Transaction transaction,
                   int flag)
                     throws java.lang.Exception

Description copied from interface: XACapable

This method is called to delist any XA resources the given object has previously enlisted to this XA transaction.

Specified by:

delistResources in interface XACapable

Parameters:

transaction - the transaction to delist resources from

flag - is the flag used by JTA when delisting resources. It is either XAResource.TMSUCCESS, XAResource.TMSUSPEND, or XAResource.TMFAIL

Throws:

java.lang.Exception

getXAResource

protected javax.transaction.xa.XAResource getXAResource()
                                                 throws java.lang.Exception

Returns:

the XAResource associated with this Messenger if one exists

Throws:

java.lang.Exception