- com
- pcbsys
- nirvana
- client
- nQueueTransactionReader
Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers. More...
Public Member Functions | |
| abstract void | commit () throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| Commits all received events so far. More... | |
| abstract void | commit (long eventId) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| Commits all events up to the event id specified. More... | |
| abstract void | commit (long eventId, boolean ackPrevious) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| Commits all events up to the event id specified. More... | |
| 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. More... | |
| abstract void | rollback (long eventId, boolean isIndividual) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| If isIndividual then this rolls back just the event with the specified event ID. More... | |
| abstract void | rollback () throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| 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.
|
pure virtual |
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.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.
|
pure virtual |
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 |
|
pure virtual |
Commits all events up to the event id specified.
This means you can partially commit received events.
| eventId | Event ID to commit to, inclusive |
| ackPrevious | if true then all events consumed prior to this eventId will also be committed (defaults to true) |
| 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 |
|
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.
| 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 |
|
pure virtual |
If isIndividual then this rolls back just the event with the specified event ID.
This event is then pushed back onto the queue for redelivery. If !isIndividual then all events consumed after the specified event ID are rolled back.
| eventId | Event Id to rollback |
| isIndividual | If true then roll back just this event ID. Otherwise roll back all events with ID greater than or equal to this |
| 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 |
|
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.
| 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.nQueueSyncTransactionReader, com.pcbsys.nirvana.client.nQueueAsyncTransactionReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.