- com
- pcbsys
- nirvana
- client
- nSerialDurable
The serial durable implementation of nDurable. More...
Public Member Functions | |
boolean | isSerial () |
If set the durable object will queue multiple subscribers and send events to them in a serial fashion (events are processed in the order that they are published across all consumers). More... | |
![]() | |
void | ack (long[] eids) throws nIllegalArgumentException, nSessionPausedException, nSessionNotConnectedException, nRequestTimedOutException |
Acknowledge multiple events in one server call. More... | |
void | ack (long[] eids, boolean isSynchronous) throws nIllegalArgumentException, nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException |
Acknowledge multiple events in one server call. More... | |
nDurableViewer | createViewer () throws nBaseClientException |
Creates a nDurableViewer object for viewing the elements on a given durable object. More... | |
long | getOutstandingEvents () |
This method returns the number of messages outstanding to be consumed for this named object. More... | |
void | remove (long eid) throws nBaseClientException |
If supported this method will attempt to remove the event with the corresponding event ID from the durable object. More... | |
void | remove (long start, long end) throws nBaseClientException |
If supported this method will attempt to remove events between the start and end events on a durable. More... | |
void | remove (String filter) throws nBaseClientException |
If supported this method will attempt to remove events matching a filter on a durable. More... | |
void | removeAll () throws nBaseClientException |
If supported this method will attempt to remove all events on a durable. More... | |
![]() | |
void | ack (long[] eids) throws nIllegalArgumentException, nSessionPausedException, nSessionNotConnectedException, nRequestTimedOutException |
Acknowledge multiple events in one server call. More... | |
void | ack (long[] eids, boolean isSynchronous) throws nIllegalArgumentException, nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException |
Acknowledge multiple events in one server call. More... | |
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... | |
String | getName () |
Returns the name of this client context. More... | |
long | getOutstandingEvents () |
Returns the number of outstanding messages to be consumed for this durable object. More... | |
boolean | isClusterWide () |
Does this named object exist across the cluster. More... | |
boolean | isDurableObjectInvalid () |
When a store is removed (or modified which entails a remove and create) then these logical representations can become invalid Once they are invalid you must perform a findChannel again on the nSession to acquire the latest object. More... | |
boolean | isPersistent () |
Returns if the durable names state is saved to disk on the server or not. More... | |
boolean | isSerial () |
If set the named object will queue multiple subscribers and send events to them in a serial fashion (events are processed in the order that they are published across all consumers). More... | |
boolean | isShared () |
If set the named object will queue multiple subscribers and send events to them in a round-robin fashion. More... | |
The serial durable implementation of nDurable.
boolean com.pcbsys.nirvana.client.nSerialDurable.isSerial | ( | ) |
If set the durable object will queue multiple subscribers and send events to them in a serial fashion (events are processed in the order that they are published across all consumers).