org.codehaus.activemq.jca
Class XAEndpoint
java.lang.Object
org.codehaus.activemq.jca.XAEndpoint
- All Implemented Interfaces:
- MessageEndpoint, MessageListener
- public class XAEndpoint
- extends Object
- implements MessageEndpoint, MessageListener
An XA based Endpoint which uses an XA transaction per message delivery.
- Version:
- $Revision: 1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
XAEndpoint
public XAEndpoint(MessageListener messageListener,
XAResource xaResource,
TransactionManager transactionManager)
beforeDelivery
public void beforeDelivery(Method method)
throws NoSuchMethodException,
ResourceException
- Specified by:
beforeDelivery
in interface MessageEndpoint
- Throws:
NoSuchMethodException
ResourceException
afterDelivery
public void afterDelivery()
throws ResourceException
- Specified by:
afterDelivery
in interface MessageEndpoint
- Throws:
ResourceException
onMessage
public void onMessage(Message message)
- Specified by:
onMessage
in interface MessageListener
release
public void release()
- Specified by:
release
in interface MessageEndpoint
doRollback
protected void doRollback(Exception e)
throws ResourceException
- Throws:
ResourceException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.