- com
- pcbsys
- nirvana
- client
- nQueueTransactionReader
Provides the basic interface for transactional queue operations, used by the synchronous and asynchronous transactional queue readers. More...
#include <nQueueTransactionReader.h>
Public Member Functions | |
virtual void | commit ()=0 |
Commits all received events so far. More... | |
virtual void | commit (longlong eventId)=0 |
Commits all events up to the event id specified. More... | |
virtual void | rollback ()=0 |
Rolls back all received events that have not been committed or rolled back previously. More... | |
virtual void | rollback (longlong eventId)=0 |
Rolls back all events up to the specified event id that have not been committed or rolled back 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::nQueueSyncTransactionReader, and com::pcbsys::nirvana::client::nQueueAsyncTransactionReader.
|
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 |
Implemented in com::pcbsys::nirvana::client::nQueueSyncTransactionReader, and com::pcbsys::nirvana::client::nQueueAsyncTransactionReader.
|
pure virtual |
Rolls back all received events that have not been committed or rolled back 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, and com::pcbsys::nirvana::client::nQueueAsyncTransactionReader.
|
pure virtual |
Rolls back all events up to the specified event id that have not been committed or rolled back 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::nQueueSyncTransactionReader, and com::pcbsys::nirvana::client::nQueueAsyncTransactionReader.