This class represent a Priority Durable implementation. More...
Public Member Functions | |
override bool | isPriorityEnabled () |
If set the durable object will queue multiple subscription such that the first subscriber will receive all events until it either disconnects or deletes the subscription, at which time, the next subscription request will start to receive events. More... | |
Public Member Functions inherited from com.pcbsys.nirvana.client.nBaseTopicDurable | |
override void | acknowledge (nConsumeEventToken eventToken, bool isSynchronous) |
Sends an acknowledge request to the server for the given event id. More... | |
override nDurableViewer | createViewer () |
Creates a nDurableViewer object for viewing the elements on a given durable object. More... | |
override void | remove (long eid) |
If supported, the method will attempt to remove the event with the given event ID from the durable object. More... | |
override void | remove (long start, long end) |
If supported, the method will attempt to remove the events within the specified range from the durable object. More... | |
override void | remove (string filter) |
If supported, the method will attempt to remove all events from the durable object which are matching the given filter. More... | |
override void | removeAll () |
If supported, the method will attempt to remove all events from the durable object. More... | |
override void | rollback (nConsumeEventToken eventToken, bool isSynchronous) |
Rollbacks the given eventToken. More... | |
Public Member Functions inherited from com.pcbsys.nirvana.client.nNamedObject | |
long | getEID () |
Returns the current event ID that this named context is bound to More... | |
long | getId () |
Returns the unique ID of this client context. More... | |
long | getLength () |
Returns the total number of events for this particular named context. More... | |
string | getName () |
Returns the name of this client context More... | |
string | getSelector () |
Selector used for this durable object to filter events. More... | |
bool | isClusterWide () |
Does this named object exist across the cluster More... | |
bool | isPersistent () |
Will this named object be restored after the Realm Server has been restarted More... | |
virtual bool | isQueued () |
Indicates whether the shared durable object is backed with a hidden queue. More... | |
virtual bool | isSerial () |
Indicates whether the durable object is shared. More... | |
virtual bool | isShared () |
Indicates whether the durable object is shared. More... | |
This class represent a Priority Durable implementation.
Two subscribers can hold a subscription to the same durable object. One is given priority and will process events during normal operation. If, however, the subscriber with priority is disconnected and is unable to process events, the second subscriber to that durable object will take over and continue to process events as they come in. This allows failover, with backup subscribers handling events if the subscriber with priority goes down.
|
virtual |
If set the durable object will queue multiple subscription such that the first subscriber will receive all events until it either disconnects or deletes the subscription, at which time, the next subscription request will start to receive events.
Reimplemented from com.pcbsys.nirvana.client.nNamedObject.