Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers. More...
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... | |
Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers.
void com.pcbsys.nirvana.client.nQueueTransactionReader.commit | ( | ) |
Commits all received events so far.
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.nQueueSyncTransactionFragmentReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.
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.
eventId | Event ID to commit to, inclusive |
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.nQueueSyncTransactionFragmentReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.
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.
eventId | Event Id to rollback to, inclusive |
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.nQueueSyncTransactionFragmentReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.
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.
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.nQueueSyncTransactionFragmentReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.