com.pcbsys.nirvana.client.nQueueTransactionReader Interface Reference

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:

com.pcbsys.nirvana.client.nQueueAsyncTransactionReader com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader com.pcbsys.nirvana.client.nQueueSyncTransactionReader

Public Member Functions

abstract void commit (long eventId) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException
 Commits all events up to the event id specified.
abstract void commit () throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException
 Commits all received events so far.
abstract void rollback () throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException
 Rollbacks all received events that have not been committed or rollbacked previously.
abstract void rollback (long eventId) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException
 Rollbacks all events up to the specified event id that have not been committed or rollbacked previously.

Detailed Description

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

Member Function Documentation

abstract void com.pcbsys.nirvana.client.nQueueTransactionReader.commit ( long  eventId  )  throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException [pure virtual]

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

abstract void com.pcbsys.nirvana.client.nQueueTransactionReader.commit (  )  throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException [pure virtual]

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

Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.

abstract void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback (  )  throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException [pure virtual]

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

Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.

abstract void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback ( long  eventId  )  throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException [pure virtual]

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