SpyXAResourceManager

Overview

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS (src) NEXT CLASS (src)

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq
Class SpyXAResourceManager

java.lang.Object
  org.jboss.mq.SpyXAResourceManager

All Implemented Interfaces:: java.io.Serializable

public class SpyXAResourceManager
extends java.lang.Object
implements java.io.Serializable

This class implements the ResourceManager used for the XAResources used int JBossMQ.

See Also:: Serialized Form

Constructor Summary
`SpyXAResourceManager(Connection (src) conn)` Create a new SpyXAResourceManager

Method Summary
`void`	`ackMessage(java.lang.Object xid, SpyMessage (src) msg)` Acknowledge a message
`void`	`addMessage(java.lang.Object xid, SpyMessage (src) msg)`
`void`	`commit(java.lang.Object xid, boolean onePhase)`
`java.lang.Object`	`convertTx(java.lang.Long anonXid, Xid (src) xid)`
`void`	`endTx(java.lang.Object xid, boolean success)`
`java.lang.Long`	`getNewXid()`
`java.lang.Object`	`joinTx(Xid (src) xid)`
`int`	`prepare(java.lang.Object xid)`
`java.lang.Object`	`resumeTx(Xid (src) xid)`
`void`	`rollback(java.lang.Object xid)`
`java.lang.Object`	`startTx()`
`java.lang.Object`	`startTx(Xid (src) xid)`
`java.lang.Object`	`suspendTx(Xid (src) xid)`

Methods inherited from class java.lang.Object

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

Constructor Detail

SpyXAResourceManager

public SpyXAResourceManager(Connection (src)  conn)

Create a new SpyXAResourceManager
Parameters:: conn - the connection

Method Detail

ackMessage

public void ackMessage(java.lang.Object xid,
                       SpyMessage (src)  msg)
                throws JMSException (src)

Acknowledge a message

Parameters:: xid - the xid; msg - the message
Throws:: JMSException (src) - for any error

addMessage

public void addMessage(java.lang.Object xid,
                       SpyMessage (src)  msg)
                throws JMSException (src)

Throws:: JMSException (src)

commit

public void commit(java.lang.Object xid,
                   boolean onePhase)
            throws XAException (src) ,
                   JMSException (src)

Throws:: XAException (src); JMSException (src)

endTx

public void endTx(java.lang.Object xid,
                  boolean success)
           throws XAException (src)

Throws:: XAException (src)

joinTx

public java.lang.Object joinTx(Xid (src)  xid)
                        throws XAException (src)

Throws:: XAException (src)

prepare

public int prepare(java.lang.Object xid)
            throws XAException (src) ,
                   JMSException (src)

Throws:: XAException (src); JMSException (src)

resumeTx

public java.lang.Object resumeTx(Xid (src)  xid)
                          throws XAException (src)

Throws:: XAException (src)

rollback

public void rollback(java.lang.Object xid)
              throws XAException (src) ,
                     JMSException (src)

Throws:: XAException (src); JMSException (src)

getNewXid

public java.lang.Long getNewXid()

startTx

public java.lang.Object startTx()

startTx

public java.lang.Object startTx(Xid (src)  xid)
                         throws XAException (src)

Throws:: XAException (src)

suspendTx

public java.lang.Object suspendTx(Xid (src)  xid)
                           throws XAException (src)

Throws:: XAException (src)

convertTx

public java.lang.Object convertTx(java.lang.Long anonXid,
                                  Xid (src)  xid)
                           throws XAException (src)