This Reader enables the client to receive all events asynchronous. More...
Public Member Functions | |
void | commit () |
Commits all received events so far. More... | |
void | commit (long eventId) |
Commits all events up to the event id specified. More... | |
void | rollback () |
Rolls back all received events that have not been committed or rolled back previously. More... | |
void | rollback (long eventId) |
Rolls back all events up to the specified event id that have not been committed or rolled back previously. More... | |
![]() | |
override void | close () |
Close the subscription, and notify the server | |
override void | closeLocally () |
Close the subscription, but do not notify the server | |
bool | isPaused () |
Returns true if the subscription of the reader is currently paused. More... | |
void | pauseReader () |
Pause the subscription of the nQueueAsyncReader. More... | |
void | resumeReader () |
Resumes the subscription of the nQueueAsyncReader. More... | |
![]() | |
void | destroyReader () |
This call will release any outstanding resources on the server and close the reader. More... | |
void | destroyReaderLocally () |
This call will close local reader resources but remain subscribed at the server Any future calls to this object will work unless destroyReader() is called More... | |
bool | hasConsumedEvents () |
Method to see whether the reader has consumed any events. More... | |
bool | isClosed () |
When a reader is closed, the physical subscription is closed at the server. More... | |
bool | isClosedLocally () |
A reader can be closed, but the physical subscription queue is not closed at the server. More... | |
nConsumeEvent[] | peek (nQueuePeekContext context) |
Performs a non destructive read More... | |
Additional Inherited Members | |
![]() | |
static nQueuePeekContext | createContext () |
Creates a Queue Peek Context, which is used to traverse the queue. More... | |
static nQueuePeekContext | createContext (int windowSize) |
Creates a Queue Peek Context, which is used to traverse the queue. More... | |
static nQueuePeekContext | createContext (int windowSize, string selector) |
Creates a Queue Peek Context, which is used to traverse the queue. More... | |
This Reader enables the client to receive all events asynchronous.
The callback method was passed as part of the nQueueReaderContext. This class provides no pop
methods, since it is all asynchronous delivery.
void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.commit | ( | ) |
Commits all received events so far.
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.commit | ( | long | eventId | ) |
Commits all events up to the event id specified.
This means you can partially commit received events.
eventId | Event ID to commit to, inclusive |
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.rollback | ( | ) |
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.
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
void com.pcbsys.nirvana.client.nQueueAsyncTransactionReader.rollback | ( | long | eventId | ) |
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 |
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.