org.jboss.narayana.rest.bridge.inbound

Class InboundBridge

java.lang.Object

org.jboss.narayana.rest.bridge.inbound.InboundBridge

All Implemented Interfaces:

SerializableXAResourceDeserializer, Serializable, XAResource

public final class InboundBridge
extends Object
implements XAResource, SerializableXAResourceDeserializer, Serializable

Author:

Gytis Trikleris

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	XARESOURCE_FORMAT_ID Unique (well, hopefully) formatId so we can distinguish our own Xids.

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

Constructors

Constructor and Description
InboundBridge() Empty constructor for serialisation.
InboundBridge(Xid xid, String enlistmentUrl) Constructor creates new transaction and enlists himself to it.

Method Summary

Modifier and Type	Method and Description
boolean	canDeserialze(String className) Can this SerializableXAResourceDeserializer handle the specified classname.
void	commit(Xid xid, boolean b) Following methods are not really used.
XAResource	deserialze(ObjectInputStream ois) Deserialize the XAResource.
void	end(Xid xid, int i)
boolean	equals(Object o)
void	forget(Xid xid)
String	getEnlistmentUrl()
int	getTransactionTimeout()
Xid	getXid()
int	hashCode()
boolean	isSameRM(XAResource resource)
int	prepare(Xid xid)
Xid[]	recover(int i)
void	rollback(Xid xid)
void	setEnlistmentUrl(String enlistmentUrl)
boolean	setTransactionTimeout(int i)
void	setXid(Xid xid)
void	start()
void	start(Xid xid, int i)
void	stop()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

XARESOURCE_FORMAT_ID

public static final int XARESOURCE_FORMAT_ID

Unique (well, hopefully) formatId so we can distinguish our own Xids.

See Also:

Constant Field Values

Constructor Detail

InboundBridge

public InboundBridge()

Empty constructor for serialisation.

InboundBridge

public InboundBridge(Xid xid,
                     String enlistmentUrl)

Constructor creates new transaction and enlists himself to it.

Parameters:

xid -

enlistmentUrl -

Method Detail

start

public void start()

stop

public void stop()

getXid

public Xid getXid()

setXid

public void setXid(Xid xid)

getEnlistmentUrl

public String getEnlistmentUrl()

setEnlistmentUrl

public void setEnlistmentUrl(String enlistmentUrl)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

See Also:

Object.equals(Object)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

canDeserialze

public boolean canDeserialze(String className)

Description copied from interface: SerializableXAResourceDeserializer

Can this SerializableXAResourceDeserializer handle the specified classname.

Specified by:

canDeserialze in interface SerializableXAResourceDeserializer

Parameters:

className - The name of the class to deserialize.

Returns:

A flag to indicate where the deserializer is aware of the Serializable XAResource.

deserialze

public XAResource deserialze(ObjectInputStream ois)
                      throws IOException,
                             ClassNotFoundException

Description copied from interface: SerializableXAResourceDeserializer

Deserialize the XAResource.

Specified by:

deserialze in interface SerializableXAResourceDeserializer

Parameters:

ois - The input stream to read from.

Returns:

An XAResource

Throws:

IOException - If the ObjectInputStream.readObject() fails.

ClassNotFoundException - If the ObjectInputStream.readObject() fails.

commit

public void commit(Xid xid,
                   boolean b)
            throws XAException

Following methods are not really used. They are required because InboundBridge has to implement XAResource interface for recovery.

Specified by:

commit in interface XAResource

Throws:

XAException

end

public void end(Xid xid,
                int i)
         throws XAException

Specified by:

end in interface XAResource

Throws:

XAException

forget

public void forget(Xid xid)
            throws XAException

Specified by:

forget in interface XAResource

Throws:

XAException

getTransactionTimeout

public int getTransactionTimeout()
                          throws XAException

Specified by:

getTransactionTimeout in interface XAResource

Throws:

XAException

isSameRM

public boolean isSameRM(XAResource resource)
                 throws XAException

Specified by:

isSameRM in interface XAResource

Throws:

XAException

prepare

public int prepare(Xid xid)
            throws XAException

Specified by:

prepare in interface XAResource

Throws:

XAException

recover

public Xid[] recover(int i)
              throws XAException

Specified by:

recover in interface XAResource

Throws:

XAException

rollback

public void rollback(Xid xid)
              throws XAException

Specified by:

rollback in interface XAResource

Throws:

XAException

setTransactionTimeout

public boolean setTransactionTimeout(int i)
                              throws XAException

Specified by:

setTransactionTimeout in interface XAResource

Throws:

XAException

start

public void start(Xid xid,
                  int i)
           throws XAException

Specified by:

start in interface XAResource

Throws:

XAException