- com
- pcbsys
- nirvana
- client
- nSharedDurableQueued
The Queue shared durable implementation of nSharedDurable. More...
Public Member Functions | |
nDurableViewer | createViewer () throws nSessionPausedException, nRequestTimedOutException, nUnknownRemoteRealmException, nIllegalArgumentException, nSessionNotConnectedException, nIllegalChannelMode, nUnexpectedResponseException, nChannelNotFoundException, nSecurityException |
Creates a nDurableViewer object for viewing the elements on a given durable object. More... | |
long | getSharedNamedObjectOutstandingEvents () |
If this object is shared, this method returns the number of messages outstanding to be consumed for this named object. More... | |
boolean | isQueued () |
Returns true if the Shared Durable depends on a hidden queue implementation. More... | |
void | remove (long eid) throws nIllegalStateException |
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 nIllegalStateException |
If supported this method will attempt to remove events between the start and end events on a durable. More... | |
void | remove (String filter) throws nIllegalStateException |
If supported this method will attempt to remove events matching a filter on a durable. More... | |
void | removeAll () throws nIllegalStateException |
If supported this method will attempt to remove all events on a durable. More... | |
Public Member Functions inherited from com.pcbsys.nirvana.client.nSharedDurable | |
boolean | isShared () |
Returns true if this is a shared durable implementation. More... | |
Public Member Functions inherited from com.pcbsys.nirvana.client.nIndexedDurable | |
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 | getOutstandingEvents () |
This method returns the number of messages outstanding to be consumed for this named object. More... | |
Public Member Functions inherited from com.pcbsys.nirvana.client.nNamedObject | |
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 () |
If this object is shared, this method returns the number of messages outstanding to be consumed for this named object. More... | |
long | getSharedNamedObjectOutstandingEvents () |
If this object is shared, this method returns the number of messages outstanding to be consumed for this named object. More... | |
boolean | isClusterWide () |
Does this named object exist across the cluster. More... | |
boolean | isPersistent () |
Will this named object be restored after the Realm Server has been restarted. More... | |
boolean | isPriorityEnabled () |
If set the named 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... | |
boolean | isQueued () |
If set the named object will be having hidden queue based implementation. More... | |
boolean | isSerial () |
If set the named object will queue multiple subscribers and send events to them in a serial fashion. More... | |
boolean | isShared () |
If set the named object will queue multiple subscribers and send events to them in a round-robin fashion. More... | |
The Queue shared durable implementation of nSharedDurable.
|
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 |
Reimplemented from com.pcbsys.nirvana.client.nIndexedDurable.
long com.pcbsys.nirvana.client.nSharedDurableQueued.getSharedNamedObjectOutstandingEvents | ( | ) |
If this object is shared, 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
boolean com.pcbsys.nirvana.client.nSharedDurableQueued.isQueued | ( | ) |
Returns true if the Shared Durable depends on a hidden queue implementation.
|
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. |
Reimplemented from com.pcbsys.nirvana.client.nIndexedDurable.
|
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 |
Reimplemented from com.pcbsys.nirvana.client.nIndexedDurable.
|
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 |
Reimplemented from com.pcbsys.nirvana.client.nIndexedDurable.
|
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 |
Reimplemented from com.pcbsys.nirvana.client.nIndexedDurable.