- com
- pcbsys
- nirvana
- client
- nIndexedDurable
A base class for all implementations of shared nDurable classes. More...
Public Member Functions | |
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... | |
A base class for all implementations of shared nDurable classes.
void com.pcbsys.nirvana.client.nIndexedDurable.ack | ( | long[] | eids | ) | throws nIllegalArgumentException, nSessionPausedException, nSessionNotConnectedException, nRequestTimedOutException |
Acknowledge multiple events in one server call.
The first argument contains all of the event IDs that you want to commit. This is functionally equivalent to calling nConsumeEvent.ack() for each event.
eids | an array of the event IDs to be acknowledged. |
nIllegalArgumentException | thrown if the event IDs were not consumed by this connection or if the named object is not shared |
nSessionNotConnectedException | we cannot write to the server if the session is not open |
nSessionPausedException | we cannot write to the server if the session is not open |
nRequestTimedOutException | the server did not respond within the time allocated |
void com.pcbsys.nirvana.client.nIndexedDurable.ack | ( | long[] | eids, |
boolean | isSynchronous | ||
) | throws nIllegalArgumentException, nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException |
Acknowledge multiple events in one server call.
The first argument contains all of the event IDs that you want to commit. This is functionally equivalent to calling nConsumeEvent.ack() for each event.
eids | an array of the event IDs to be acknowledged. |
isSynchronous | if true, the thread will be held until the server has responded to the request |
nIllegalArgumentException | thrown if the event IDs were not consumed by this connection or if the named object is not shared |
nSessionNotConnectedException | we cannot write to the server if the session is not open |
nSessionPausedException | we cannot write to the server if the session is not open |
nRequestTimedOutException | the server did not respond within the time allocated |
|
virtual |
Creates a nDurableViewer object for viewing the elements on a given durable object.
Consuming events through this object using the nDurableViewer::next() method will not consume or acknowledge the events for the given durable.
nBaseClientException | this exception may be thrown by implementors if creating the viewer fails |
Implements com.pcbsys.nirvana.client.nDurable.
long com.pcbsys.nirvana.client.nIndexedDurable.getOutstandingEvents | ( | ) |
This method returns the number of messages outstanding to be consumed for this named object.
If the named object is not shared then this method will always return -1
|
virtual |
If supported this method will attempt to remove the event with the corresponding event ID from the durable object.
Currently there is only limited support for removing events from a durable subscription. Shared durable objects which are not backed by a queue are the only durable objects which support this operation. All other implementors of this interface will throw a nIllegalStateException when invoked.
eid | - the EventID to purge from. |
nIllegalStateException | If the durable object is not shared this exception will be thrown. |
Implements com.pcbsys.nirvana.client.nDurable.
|
virtual |
If supported this method will attempt to remove events between the start and end events on a durable.
Currently there is only limited support for removing events from a durable subscription. Shared durable objects which are not backed by a queue are the only durable objects which support this operation. All other implementors of this interface will throw a nIllegalStateException when invoked.
start | - the EventID to start the purge from. |
end | - the end EventID to purge to. |
nIllegalStateException | If the durable object is not shared this exception will be thrown. |
nBaseClientException | If the remove operation fails this exception will be thrown |
Implements com.pcbsys.nirvana.client.nDurable.
|
virtual |
If supported this method will attempt to remove events matching a filter on a durable.
Currently there is only limited support for removing events from a durable subscription. Shared durable objects which are not backed by a queue are the only durable objects which support this operation. All other implementors of this interface will throw a nIllegalStateException when invoked.
filter | - string value of the filter to purge by |
nIllegalStateException | If the durable object is not shared this exception will be thrown. |
nBaseClientException | If the remove operation fails this exception will be thrown |
Implements com.pcbsys.nirvana.client.nDurable.
|
virtual |
If supported this method will attempt to remove all events on a durable.
Currently there is only limited support for removing events from a durable subscription. Shared durable objects which are not backed by a queue are the only durable objects which support this operation. All other implementors of this interface will throw a nIllegalStateException when invoked.
nIllegalStateException | If the durable object is not shared this exception will be thrown. |
nBaseClientException | If the remove operation fails this exception will be thrown |
Implements com.pcbsys.nirvana.client.nDurable.