Glossary:
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...

Public Member Functions | |
| void | commit (long eventId) |
| Commits all events up to the event id specified. | |
| void | commit () |
| Commits all received events so far. | |
| void | rollback () |
| Rollbacks all received events that have not been committed or rollbacked previously. | |
| void | rollback (long eventId) |
| 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
| 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
Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.
| 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
Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.
| 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
Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.
| 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
Implemented in com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.
