Glossary:
com.pcbsys.nirvana.client.nQueueAsyncTransactionReader Class Reference
This class extends the asynchronous queue model by adding the transactional ability to the reader. More...
Inheritance diagram for com.pcbsys.nirvana.client.nQueueAsyncTransactionReader:
Public Member Functions | |
| final void | commit (final long eventId) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| Commits all events up to the event id specified. | |
| final void | commit () throws nSessionNotConnectedException, nRequestTimedOutException, nSessionPausedException,nIllegalStateException |
| Commits all received events so far. | |
| final void | rollback (final long eventId) throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
| Rollbacks all events up to the specified event id that have not been committed or rollbacked previously. | |
| final void | rollback () throws nSessionNotConnectedException, nRequestTimedOutException, nSessionPausedException,nIllegalStateException |
| Rollbacks all received events that have not been committed or rollbacked previously. | |
Detailed Description
This class extends the asynchronous queue model by adding the transactional ability to the reader.This enables the client to commit already recieved events or roll them back. When a rollback occurs the events that have not been committed by this client are then pushed back onto the queue for redelivery to other clients.
Member Function Documentation
| final void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.commit | ( | final long | eventId | ) | throws nSessionNotConnectedException, nSessionPausedException,nRequestTimedOutException, nIllegalStateException |
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
| final void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.commit | ( | ) | throws nSessionNotConnectedException, nRequestTimedOutException, nSessionPausedException,nIllegalStateException [virtual] |
| final void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.rollback | ( | final 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.
- Parameters:
-
eventId Event Id to rollback to, inclusive
| final void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.rollback | ( | ) | throws nSessionNotConnectedException, nRequestTimedOutException, nSessionPausedException,nIllegalStateException [virtual] |
Rollbacks all received events that have not been committed or rollbacked previously.
These events are then pushed back onto the queue for redelivery.
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
