Module org.mule.sdk.api

Package org.mule.sdk.api.queue

Interface QueueSession

All Superinterfaces:

XAResource

@NoImplement
public interface QueueSession
extends XAResource

Session for executing operation over queues.

Since:

1.0

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

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

Method Summary

Modifier and Type	Method	Description
void	begin()	Starts a transaction to execute operations over a set of queue with atomicity.
void	commit()	Commits a transaction started with begin()
Queue	getQueue(String name)	Retrieves a queue.
void	rollback()	Rollbacks a transaction started with begin()

Methods inherited from interface javax.transaction.xa.XAResource

commit, end, forget, getTransactionTimeout, isSameRM, prepare, recover, rollback, setTransactionTimeout, start

Method Details

getQueue

Queue getQueue(String name)

Retrieves a queue.

Parameters:

name - identifier of the queue to retrieve

Returns:

the queue

begin

void begin()
    throws ResourceManagerException

Starts a transaction to execute operations over a set of queue with atomicity.

Throws:

ResourceManagerException

commit

void commit()
     throws ResourceManagerException

Commits a transaction started with begin()

Throws:

ResourceManagerException

rollback

void rollback()
       throws ResourceManagerException

Rollbacks a transaction started with begin()

Throws:

ResourceManagerException