Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers. More...

Inheritance diagram for com.pcbsys.nirvana.client.nQueueTransactionReader:

Public Member Functions
void	commit ()
	Commits all received events so far. More...

void	commit (long eventId)
	Commits all events up to the event id specified. More...

void	rollback (long eventId)
	Rollbacks all events up to the specified event id that have not been committed or rollbacked previously. More...

void	rollback ()
	Rollbacks all received events that have not been committed or rollbacked previously. More...

Detailed Description

Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers.

Member Function Documentation

void com.pcbsys.nirvana.client.nQueueTransactionReader.commit ( )

Commits all received events so far.

Exceptions

nSessionNotConnectedException	Client is not currently connected to the server
nSessionPausedException	The session is currently paused
nIllegalStateException	The operation could not complete because of a session/connection error
nRequestTimedOutException	The server failed to respond with the specified timeout

void com.pcbsys.nirvana.client.nQueueTransactionReader.commit ( long eventId )

Commits all events up to the event id specified.

This means you can partially commit received events.

Parameters

eventId Event ID to commit to, inclusive

Exceptions

nSessionNotConnectedException	Client is not currently connected to the server
nSessionPausedException	The session is currently paused
nIllegalStateException	The operation could not complete because of a session/connection error
nRequestTimedOutException	The server failed to respond with the specified timeout

void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback ( long eventId )

Rollbacks all events up to the specified event id that have not been committed or rollbacked previously.

These events are then pushed back onto the queue for redelivery.

Parameters

eventId Event Id to rollback to, inclusive

Exceptions

nSessionNotConnectedException	Client is not currently connected to the server
nSessionPausedException	The session is currently paused
nIllegalStateException	The operation could not complete because of a session/connection error
nRequestTimedOutException	The server failed to respond with the specified timeout

void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback ( )

Rollbacks all received events that have not been committed or rollbacked previously.

These events are then pushed back onto the queue for redelivery.

Exceptions

nSessionNotConnectedException	Client is not currently connected to the server
nSessionPausedException	The session is currently paused
nIllegalStateException	The operation could not complete because of a session/connection error
nRequestTimedOutException	The server failed to respond with the specified timeout