- 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 | |
| void | commit () throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
| Commits all received events so far. More... | |
| void | commit (long eventId) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
| Commits all events up to the event id specified. More... | |
| void | commit (long eventId, boolean ackPrevious) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
| Commits all events up to the event id specified. More... | |
| 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... | |
| 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... | |
| 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.
| void com.pcbsys.nirvana.client.nQueueTransactionReader.commit | ( | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
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.nQueueSyncTransactionFragmentReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionReader.
| void com.pcbsys.nirvana.client.nQueueTransactionReader.commit | ( | long | eventId | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
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 |
| void com.pcbsys.nirvana.client.nQueueTransactionReader.commit | ( | long | eventId, |
| boolean | ackPrevious | ||
| ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
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 |
| void com.pcbsys.nirvana.client.nQueueTransactionReader.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.
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 |
| void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback | ( | long | eventId, |
| boolean | isIndividual | ||
| ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
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 |
| void com.pcbsys.nirvana.client.nQueueTransactionReader.rollback | ( | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
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.nQueueAsyncTransactionReader, com.pcbsys.nirvana.client.nQueueSyncTransactionReader, and com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.