This class is a Nirvana channel, offering the Nirvana channel related services More...
Public Member Functions | |
void | addConnectionListener (nChannelConnectionListener listener) |
Adds a nChannelConnectionListener to this channel so that when new connections are made to this channel the listener is notified More... | |
void | addConnectionListener (nChannelConnectionListener listener, bool isSync) |
Adds a nChannelConnectionListener to this channel so that when new connections are made to this channel the listener is notified More... | |
void | addSubscriber (nEventListener nel) |
Registers the specified nEventListener as a subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, long eid) |
Registers the specified nEventListener as a subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, string selector) |
Registers the specified nEventListener as a subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, string selector, long eid) |
Registers the specified nEventListener as a subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, nNamedObject name, string selector, bool AutoAck) |
Registers the specified nEventListener as a named subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, nNamedObject name) |
Registers the specified nEventListener as a named subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, nNamedObject name, string selector, bool AutoAck, nNamedPriorityListener listener) |
Registers the specified nEventListener as a named subscriber to this channel. More... | |
void | addSubscriber (nEventListener nel, nNamedObject name, nNamedPriorityListener listener) |
Registers the specified nEventListener as a named subscriber to this channel. More... | |
nChannelIterator | createIterator () |
Create a default channel iterator starting at the beginning of the channel More... | |
nChannelIterator | createIterator (string selector) |
Create a default channel iterator starting at the beginning of the channel with the events which match the selector being returned More... | |
nChannelIterator | createIterator (long startEID) |
Create a default channel iterator starting at the EID specified More... | |
nChannelIterator | createIterator (string selector, long startEID) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned More... | |
nChannelIterator | createIterator (nNamedObject name) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned More... | |
nChannelIterator | createIterator (nNamedObject name, string selector) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned More... | |
nNamedObject | createNamedObject (string name) |
Creates a named object on the channel with the given name More... | |
nNamedObject | createNamedObject (string name, long startEID) |
Creates a named object on the channel with the given name More... | |
nNamedObject | createNamedObject (string name, long startEID, bool persistent) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not More... | |
nNamedObject | createNamedObject (string name, bool persistent) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not More... | |
nNamedObject | createNamedObject (string name, bool persistent, bool clusterWide) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not More... | |
nNamedObject | createNamedObject (string name, long startEID, bool persistent, bool clusterWide) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not More... | |
nNamedObject | createNamedObject (string name, long startEID, bool persistent, bool clusterWide, bool enablePriority) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not More... | |
nRegisteredEvent | createRegisteredEvent (object keyValue) |
Creates a new nRegisteredEvent bound to this channel using the keyValue as its unique id. More... | |
nRegisteredEvent | createRegisteredEvent (object keyValue, bool isTransactional) |
Creates a new nRegisteredEvent bound to this channel using the keyValue as its unique id. More... | |
void | deleteJoin (nChannel destination) |
Deletes a join between this channel and the channel referenced in the destination parameter More... | |
void | deleteJoin (nQueue destination) |
Deletes a join between this channel and the queue referenced in the destination parameter More... | |
void | delNamedObject (nNamedObject name) |
Removes all references for this name on the realm Server More... | |
void | delNamedObject (string name) |
Removes all references for this name on the realm Server More... | |
nChannelAttributes | getChannelAttributes () |
Gets the channels local attributes More... | |
nJoinInformation[] | getJoinInformation () |
Returns an array of nJoinInformation objects which describe the links this channel has configured for it. More... | |
long | getLastEID () |
Gets the last event id of this channel More... | |
long | getLastStoredEID () |
Gets the last event id of this channel More... | |
string | getName () |
Gets the name of this channel More... | |
nNamedObject | getNamedObject (string name) |
Returns an instance of the nNamedObject referenced by the parameter More... | |
nNamedObject[] | getNamedObjects () |
Returns an array of all known nNamedObjects registered with this channel More... | |
int | getType () |
Gets the type of this channel More... | |
bool | isSubscribed () |
Determines whether the underlying channel is currently being subscribed to More... | |
void | joinChannel (nChannel dest, string selector) |
Sets a server based link between this channel and the channel defined within the provided nChannel. More... | |
void | joinChannel (nChannel dest) |
Sets a server based link between this channel and the channel defined within the provided nChannel. More... | |
void | joinChannel (nChannel dest, bool isRouted, int hopCount, string selector) |
Sets a server based link between this channel and the channel defined within the provided nChannel. More... | |
void | joinChannel (nChannel dest, bool isRouted, int hopCount, string selector, bool allowPurge) |
Sets a server based link between this channel and the channel defined within the provided nChannel. More... | |
void | joinChannel (nQueue dest, string selector) |
Sets a server based link between this channel and the queue defined by the dest parameter. More... | |
void | joinChannel (nQueue dest) |
Sets a server based link between this channel and the queue defined within the provided nQueue. More... | |
void | joinChannel (nQueue dest, bool isRouted, int hopCount, string selector) |
Sets a server based link between this channel and the queue defined within the provided nQueue. More... | |
void | joinChannelToArchive (nQueue dest) |
Sets a server based link between this channel and the queue defined within the provided nQueue. More... | |
void | joinChannelToArchive (nQueue dest, string selector) |
Sets a server based link between this channel and the queue defined within the provided nQueue. More... | |
void | publish (nConsumeEvent e) |
Publishes the specified nConsumeEvent to this channel More... | |
void | purgeEvent (long eidval) |
Purges a single event from this channel More... | |
void | purgeEvent (long eidval, bool purgeJoins) |
Purges a single event from this channel More... | |
void | purgeEventAsync (long eidval) |
Purges a single event from this channel and does not wait for the response from the server More... | |
void | purgeEventAsync (long eidval, bool purgeJoins) |
Purges a single event from this channel and does not wait for the response from the server More... | |
void | purgeEvents (long startEID, long endEID) |
Purges a range of events from this channel More... | |
void | purgeEvents (long startEID, long endEID, bool purgeJoins) |
Purges a range of events from this channel More... | |
void | purgeEvents (long startEID, long endEID, string selector) |
Purges a range of events from this channel More... | |
void | purgeEvents (long startEID, long endEID, string selector, bool purgeJoins) |
Purges a range of events from this channel More... | |
void | purgeEventsAsync (long startEID, long endEID) |
Purges a range of events from this channel and does not wait for the response from the server More... | |
void | purgeEventsAsync (long startEID, long endEID, bool purgeJoins) |
Purges a range of events from this channel and does not wait for the response from the server More... | |
void | purgeEventsAsync (long startEID, long endEID, string selector) |
Purges a range of events from this channel and does not wait for the response from the server More... | |
void | purgeEventsAsync (long startEID, long endEID, string selector, bool purgeJoins) |
Purges a range of events from this channel and does not wait for the response from the server More... | |
void | removeConnectionListener () |
Removes the connection listener to this channel More... | |
void | removeConnectionListener (nChannelConnectionListener listener) |
Removes the connection listener to this channel More... | |
void | removeSubscriber (nEventListener nel) |
Unregisters the specified nEventListener as a subscriber from this channel. More... | |
void | removeSubscriber (nEventListener nel, bool waitForResponse) |
Unregisters the specified nEventListener as a subscriber from this channel. More... | |
void | reSubscribe (string selector) |
Removes the current subscriber and re-registers the nEventListener as a subscriber to this channel. More... | |
void | reSubscribe (long eid) |
Removes the current subscriber and registers the specified nEventListener as a subscriber to this channel. More... | |
void | reSubscribe (string selector, long eid) |
Removes the current subscriber and re-registers the nEventListener as a subscriber to this channel. More... | |
void | reSubscribe (nNamedObject name, string selector) |
Removes the current subscriber and registers the specified nEventListener as a named subscriber to this channel. More... | |
void | unbindNamedObject (nNamedObject name) |
Unbinds the named object from the current connection More... | |
void | unbindNamedObject (string name) |
Unbinds the named object from the current connection More... | |
![]() | |
int | getQueueSize () |
Returns the size of the underlying event queue waiting for delivery via the go method More... | |
nSession | getSession () |
Returns the nSession object that this channel belongs to More... | |
void | updateProtobufDefinitions (byte[][] descriptors) |
Sets the protobuf descriptors for this channel. More... | |
This class is a Nirvana channel, offering the Nirvana channel related services
void com.pcbsys.nirvana.client.nChannel.addConnectionListener | ( | nChannelConnectionListener | listener | ) |
Adds a nChannelConnectionListener to this channel so that when new connections are made to this channel the listener is notified
listener | to add |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits, or has already been set. |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.addConnectionListener | ( | nChannelConnectionListener | listener, |
bool | isSync | ||
) |
Adds a nChannelConnectionListener to this channel so that when new connections are made to this channel the listener is notified
listener | to add |
isSync | the call is synchronous |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits, or has already been set. |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel | ) |
Registers the specified nEventListener as a subscriber to this channel.
The subscriber will receive all events contained in this channel.
nel | the nEventListener object to be registered as a subscriber |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
long | eid | ||
) |
Registers the specified nEventListener as a subscriber to this channel.
The subscriber will receive all events with event id greater than or equal to the one specified.
nel | the nEventListener object to be registered as a subscriber |
eid | a long specifying the subscription's start eid |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
string | selector | ||
) |
Registers the specified nEventListener as a subscriber to this channel.
The subscriber will receive all events contained in this channel, apart from the ones restricted by the specified filter.
nel | the nEventListener object to be registered as a subscriber |
selector | a string specifying a filter to this subscription request |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
string | selector, | ||
long | eid | ||
) |
Registers the specified nEventListener as a subscriber to this channel.
The subscriber will receive all events with event id greater than or equal to the one specified, apart from the ones restricted by the specified filter.
nel | the nEventListener object to be registered as a subscriber |
selector | a string specifying a filter to this subscription request |
eid | a long specifying the subscription's start eid |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
nNamedObject | name, | ||
string | selector, | ||
bool | AutoAck | ||
) |
Registers the specified nEventListener as a named subscriber to this channel.
The subscriber will receive all events from the last acknowledged event for the name supplied If the name is new it will start from the END of the channel.
nel | the nEventListener object to be registered as a subscriber |
name | an nNamedObject specifying a name for this subscription |
selector | a string specifying a filter to this subscription request |
AutoAck | a bool used to control whether the nirvana client will automatically ack events or if the user will ack events later |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nNameAlreadyBoundException | The name is already bound and used by another client |
nSessionPausedException | The session is currently paused |
nNameDoesNotExistException | if the server does not know about the named object |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
nNamedObject | name | ||
) |
Registers the specified nEventListener as a named subscriber to this channel.
The subscriber will receive all events from the last acknowledged event for the name supplied If the name is new it will start from the END of the channel.
nel | the nEventListener object to be registered as a subscriber |
name | a nNamedObject specifying a name for this subscription |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nNameAlreadyBoundException | The name is already bound and used by another client |
nSessionPausedException | The session is currently paused |
nNameDoesNotExistException | if the server does not know about the named object |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
nNamedObject | name, | ||
string | selector, | ||
bool | AutoAck, | ||
nNamedPriorityListener | listener | ||
) |
Registers the specified nEventListener as a named subscriber to this channel.
The subscriber will receive all events from the last acknowledged event for the name supplied If the name is new it will start from the END of the channel.
nel | the nEventListener object to be registered as a subscriber |
name | an nNamedObject specifying a name for this subscription |
selector | a string specifying a filter to this subscription request |
AutoAck | a boolean used to control whether the nirvana client will automatically ack events or if the user will ack events later |
listener | a nNamedPriorityListener which is called back when this subscription reaches the top of the queue and is now the top priority to receive events |
nSecurityException | is thrown if the caller has unsufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nNameAlreadyBoundException | The name is already bound and used by another client |
nSessionPausedException | The session is currently paused |
nNameDoesNotExistException | if the server does not know about the named object |
void com.pcbsys.nirvana.client.nChannel.addSubscriber | ( | nEventListener | nel, |
nNamedObject | name, | ||
nNamedPriorityListener | listener | ||
) |
Registers the specified nEventListener as a named subscriber to this channel.
The subscriber will receive all events from the last acknowledged event for the name supplied If the name is new it will start from the END of the channel.
nel | the nEventListener object to be registered as a subscriber |
name | a nNamedObject specifying a name for this subscription |
listener | a nNamedPriorityListener which is called back when this subscription reaches the top of the queue and is now the top priority to receive events |
nSecurityException | is thrown if the caller has unsufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nNameAlreadyBoundException | The name is already bound and used by another client |
nSessionPausedException | The session is currently paused |
nNameDoesNotExistException | if the server does not know about the named object |
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | ) |
Create a default channel iterator starting at the beginning of the channel
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | string | selector | ) |
Create a default channel iterator starting at the beginning of the channel with the events which match the selector being returned
selector | Used to specify a sub set of the current channel events |
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | long | startEID | ) |
Create a default channel iterator starting at the EID specified
startEID | The event to start iterating the channel from |
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | string | selector, |
long | startEID | ||
) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned
selector | Used to specify a sub set of the current channel events |
startEID | The event to start iterating the channel from |
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | nNamedObject | name | ) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned
name | Named Object reference to use for this iterator |
nChannelIterator com.pcbsys.nirvana.client.nChannel.createIterator | ( | nNamedObject | name, |
string | selector | ||
) |
Create a default channel iterator starting at the eid specified in the channel with the events which match the selector being returned
selector | Used to specify a sub set of the current channel events |
name | Named Object reference to use for this iterator |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name | ) |
Creates a named object on the channel with the given name
name | to create |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
long | startEID | ||
) |
Creates a named object on the channel with the given name
name | to create |
startEID | event EID to start the named object from |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
long | startEID, | ||
bool | persistent | ||
) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not
name | to create |
startEID | event EID to start the named object from |
persistent | flag to indicate to the server where to store it |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
bool | persistent | ||
) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not
name | to create |
persistent | flag to indicate to the server where to store it |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
bool | persistent, | ||
bool | clusterWide | ||
) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not
name | to create |
persistent | flag to indicate to the server where to store it |
clusterWide | flag to indicate if this named object is valid in the entire cluster |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
long | startEID, | ||
bool | persistent, | ||
bool | clusterWide | ||
) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not
name | to create |
startEID | event EID to start the named object from |
persistent | flag to indicate to the server where to store it |
clusterWide | flag to indicate if this named object is valid in the entire cluster |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject com.pcbsys.nirvana.client.nChannel.createNamedObject | ( | string | name, |
long | startEID, | ||
bool | persistent, | ||
bool | clusterWide, | ||
bool | enablePriority | ||
) |
Creates a named object on the channel with the given name and depending on the persistent flag informs the server to store the name and value to disk or not
name | to create |
startEID | event EID to start the named object from |
persistent | flag to indicate to the server where to store it |
clusterWide | flag to indicate if this named object is valid in the entire cluster |
enablePriority | flag to indicate if multiple subscriptions will be prioritized on this object |
nSecurityException | is thrown if the caller has unsufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nNameAlreadyBoundException | If the name is already in use |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
nRegisteredEvent com.pcbsys.nirvana.client.nChannel.createRegisteredEvent | ( | object | keyValue | ) |
Creates a new nRegisteredEvent bound to this channel using the keyValue as its unique id.
keyValue | Unquie Id to use for the nRegisteredEvent |
nIllegalArgumentException | if unable to create the nRegisteredEvent object |
nRegisteredEvent com.pcbsys.nirvana.client.nChannel.createRegisteredEvent | ( | object | keyValue, |
bool | isTransactional | ||
) |
Creates a new nRegisteredEvent bound to this channel using the keyValue as its unique id.
keyValue | Unquie Id to use for the nRegisteredEvent |
isTransactional | Indicates that all commits on the nRegistedEvent should use transactional symantics |
nIllegalArgumentException | if unable to create the nRegisteredEvent object |
void com.pcbsys.nirvana.client.nChannel.deleteJoin | ( | nChannel | destination | ) |
Deletes a join between this channel and the channel referenced in the destination parameter
destination | This is an nChannel object referencing the destination channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.deleteJoin | ( | nQueue | destination | ) |
Deletes a join between this channel and the queue referenced in the destination parameter
destination | This is an nQueue object referencing the destination queue |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the queue no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.delNamedObject | ( | nNamedObject | name | ) |
Removes all references for this name on the realm Server
name | the name to be removed from the server |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nNameDoesNotExistException | The name specified does not exist on the server |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.delNamedObject | ( | string | name | ) |
Removes all references for this name on the realm Server
name | the name to be removed from the server |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nNameDoesNotExistException | The name specified does not exist on the server |
nSessionPausedException | The session is currently paused, please resume |
nChannelAttributes com.pcbsys.nirvana.client.nChannel.getChannelAttributes | ( | ) |
Gets the channels local attributes
nJoinInformation [] com.pcbsys.nirvana.client.nChannel.getJoinInformation | ( | ) |
Returns an array of nJoinInformation objects which describe the links this channel has configured for it.
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
long com.pcbsys.nirvana.client.nChannel.getLastEID | ( | ) |
Gets the last event id of this channel
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nSessionPausedException | The session is currently paused |
long com.pcbsys.nirvana.client.nChannel.getLastStoredEID | ( | ) |
Gets the last event id of this channel
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nSessionPausedException | The session is currently paused |
string com.pcbsys.nirvana.client.nChannel.getName | ( | ) |
Gets the name of this channel
nNamedObject com.pcbsys.nirvana.client.nChannel.getNamedObject | ( | string | name | ) |
Returns an instance of the nNamedObject referenced by the parameter
name | of the nNamedObject |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nNameDoesNotExistException | The name specified does not exist on the server |
nSessionPausedException | The session is currently paused, please resume |
nNamedObject [] com.pcbsys.nirvana.client.nChannel.getNamedObjects | ( | ) |
Returns an array of all known nNamedObjects registered with this channel
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nSessionPausedException | The session is currently paused, please resume |
int com.pcbsys.nirvana.client.nChannel.getType | ( | ) |
Gets the type of this channel
Currently supported types are:
nChanneAttributes.MIXED_TYPE nChanneAttributes.SIMPLE_TYPE nChanneAttributes.PERSISTENT_TYPE nChanneAttributes.RELIABLE_TYPE nChanneAttributes.TRANSIENT_TYPE
bool com.pcbsys.nirvana.client.nChannel.isSubscribed | ( | ) |
Determines whether the underlying channel is currently being subscribed to
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nChannel | dest, |
string | selector | ||
) |
Sets a server based link between this channel and the channel defined within the provided nChannel.
The link has a filter applied to it, defined by the provided selector string
dest | a nChannel object defining the channel to be joined (linked) to this channel |
selector | A string defining a filter that will be applied in the join (link) of these 2 channels |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nChannel | dest | ) |
Sets a server based link between this channel and the channel defined within the provided nChannel.
dest | a nChannel object defining the channel to be joined (linked) to this channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nChannel | dest, |
bool | isRouted, | ||
int | hopCount, | ||
string | selector | ||
) |
Sets a server based link between this channel and the channel defined within the provided nChannel.
Additional parameters specify whether the event is routable or not, the maximum number of hops the event can pass through and the filter applied to the join (link).
dest | a nChannel object defining the channel to be joined (linked) to this channel |
isRouted | a bool flag specifying whether the event will be routed or not |
hopCount | an int specifying the maximum number of hops the event can pass through |
selector | A string defining a filter that will be applied in the join (link) of these 2 channels |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nChannel | dest, |
bool | isRouted, | ||
int | hopCount, | ||
string | selector, | ||
bool | allowPurge | ||
) |
Sets a server based link between this channel and the channel defined within the provided nChannel.
Additional parameters specify whether the event is routable or not, the maximum number of hops the event can pass through and the filter applied to the join (link).
dest | a nChannel object defining the channel to be joined (linked) to this channel |
isRouted | a bool flag specifying whether the event will be routed or not |
hopCount | an int specifying the maximum number of hops the event can pass through |
selector | A string defining a filter that will be applied in the join (link) of these 2 channels |
allowPurge | if allow purge is true then when the source channel is purged events source from it will also be purged |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nQueue | dest, |
string | selector | ||
) |
Sets a server based link between this channel and the queue defined by the dest parameter.
Additional parameter specifies the filter applied to the join (link).
dest | a nQueue object defining the queue to be joined (linked) to this channel |
selector | A string defining a filter that will be applied in the join (link) from the source channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nQueue | dest | ) |
Sets a server based link between this channel and the queue defined within the provided nQueue.
The link has a filter applied to it, defined by the provided selector string
dest | a nQueue object defining the queue to be joined (linked) to this channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannel | ( | nQueue | dest, |
bool | isRouted, | ||
int | hopCount, | ||
string | selector | ||
) |
Sets a server based link between this channel and the queue defined within the provided nQueue.
Additional parameters specify whether the event is routable or not, the maximum number of hops the event can pass through and the filter applied to the join (link).
dest | a nQueue object defining the queue to be joined (linked) to this channel |
isRouted | a bool flag specifying whether the event will be routed or not |
hopCount | an int specifying the maximum number of hops the event can pass through |
selector | A string defining a filter that will be applied in the join (link) from the source channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannelToArchive | ( | nQueue | dest | ) |
Sets a server based link between this channel and the queue defined within the provided nQueue.
The link has a filter applied to it, defined by the provided selector string Events will NOT be checked for duplicates since this is an archive join, any events that are published to the source will appear in the destination queue. This may result in duplicate events in the queue if the queue has multiple sources. This is by design.
dest | a nQueue object defining the queue to be joined (linked) to this channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.joinChannelToArchive | ( | nQueue | dest, |
string | selector | ||
) |
Sets a server based link between this channel and the queue defined within the provided nQueue.
Additional parameters specify whether the event is routable or not, the maximum number of hops the event can pass through and the filter applied to the join (link). Events will NOT be checked for duplicates since this is an archive join, any events that are published to the source will appear in the destination queue. This may result in duplicate events in the queue if the queue has multiple sources. This is by design.
dest | a nQueue object defining the queue to be joined (linked) to this channel |
selector | A string defining a filter that will be applied in the join (link) from the source channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nDuplicateJoinException | The join already exists on the server |
nRealmNotFoundException | The remote realm could not be found |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.publish | ( | nConsumeEvent | e | ) |
Publishes the specified nConsumeEvent to this channel
e | the nConsumeEvent object to be published to this channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nSessionNotConnectedException | The session is not currently connected to the server |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvent | ( | long | eidval | ) |
Purges a single event from this channel
eidval | a long specifying the event id of the event to be purged from the channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvent | ( | long | eidval, |
bool | purgeJoins | ||
) |
Purges a single event from this channel
eidval | a long specifying the event id of the event to be purged from the channel |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventAsync | ( | long | eidval | ) |
Purges a single event from this channel and does not wait for the response from the server
eidval | a long specifying the event id of the event to be purged from the channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventAsync | ( | long | eidval, |
bool | purgeJoins | ||
) |
Purges a single event from this channel and does not wait for the response from the server
eidval | a long specifying the event id of the event to be purged from the channel |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvents | ( | long | startEID, |
long | endEID | ||
) |
Purges a range of events from this channel
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvents | ( | long | startEID, |
long | endEID, | ||
bool | purgeJoins | ||
) |
Purges a range of events from this channel
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvents | ( | long | startEID, |
long | endEID, | ||
string | selector | ||
) |
Purges a range of events from this channel
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
selector | A messages selector which will be used to filter out only the events which match this criteria |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEvents | ( | long | startEID, |
long | endEID, | ||
string | selector, | ||
bool | purgeJoins | ||
) |
Purges a range of events from this channel
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
selector | A messages selector which will be used to filter out only the events which match this criteria |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventsAsync | ( | long | startEID, |
long | endEID | ||
) |
Purges a range of events from this channel and does not wait for the response from the server
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventsAsync | ( | long | startEID, |
long | endEID, | ||
bool | purgeJoins | ||
) |
Purges a range of events from this channel and does not wait for the response from the server
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventsAsync | ( | long | startEID, |
long | endEID, | ||
string | selector | ||
) |
Purges a range of events from this channel and does not wait for the response from the server
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
selector | A messages selector which will be used to filter out only the events which match this criteria |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.purgeEventsAsync | ( | long | startEID, |
long | endEID, | ||
string | selector, | ||
bool | purgeJoins | ||
) |
Purges a range of events from this channel and does not wait for the response from the server
startEID | a long specifying the start event id of the range of events to be purged from the channel |
endEID | a long specifying the end event id of the range of events to be purged from the channel |
selector | A messages selector which will be used to filter out only the events which match this criteria |
purgeJoins | a bool specifying if the event will be removed from all subsequent joins |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.removeConnectionListener | ( | ) |
Removes the connection listener to this channel
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.removeConnectionListener | ( | nChannelConnectionListener | listener | ) |
Removes the connection listener to this channel
listener | remove the listener |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.removeSubscriber | ( | nEventListener | nel | ) |
Unregisters the specified nEventListener as a subscriber from this channel.
The subscriber will not receive any more events.
nel | the nEventListener object to be registered as a subscriber |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.removeSubscriber | ( | nEventListener | nel, |
bool | waitForResponse | ||
) |
Unregisters the specified nEventListener as a subscriber from this channel.
The subscriber will not receive any more events.
nel | the nEventListener object to be registered as a subscriber |
waitForResponse | if true the call will block waiting for the server to complete the request |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.reSubscribe | ( | string | selector | ) |
Removes the current subscriber and re-registers the nEventListener as a subscriber to this channel.
The subscriber will receive all events on the channel apart from the ones restricted by the specified filter.
selector | a string specifying a filter to this subscription request |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
void com.pcbsys.nirvana.client.nChannel.reSubscribe | ( | long | eid | ) |
Removes the current subscriber and registers the specified nEventListener as a subscriber to this channel.
The subscriber will receive all events with event id greater than or equal to the one specified
eid | a long specifying the subscription's start eid |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.reSubscribe | ( | string | selector, |
long | eid | ||
) |
Removes the current subscriber and re-registers the nEventListener as a subscriber to this channel.
The subscriber will receive all events with event id greater than or equal to the one specified, apart from the ones restricted by the specified filter.
selector | a string specifying a filter to this subscription request |
eid | a long specifying the subscription's start eid |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nSessionPausedException | The session is currently paused |
void com.pcbsys.nirvana.client.nChannel.reSubscribe | ( | nNamedObject | name, |
string | selector | ||
) |
Removes the current subscriber and registers the specified nEventListener as a named subscriber to this channel.
The subscriber will receive all events from the last acknowledged event for the name supplied If the name is new it will start from the END of the channel.
name | a named object for this subscription |
selector | a string specifying a filter to this subscription request |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nSelectorParserException | The selector has syntax errors |
nChannelAlreadySubscribedException | A subscriber is already registered with this channel on this session |
nNameAlreadyBoundException | The name is already bound and used by another client |
nSessionPausedException | The session is currently paused |
nNameDoesNotExistException | if the server does not know about the named object |
void com.pcbsys.nirvana.client.nChannel.unbindNamedObject | ( | nNamedObject | name | ) |
Unbinds the named object from the current connection
name | the named object to be unbound |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nNameDoesNotExistException | The name specified does not exist on the server |
nSessionPausedException | The session is currently paused, please resume |
void com.pcbsys.nirvana.client.nChannel.unbindNamedObject | ( | string | name | ) |
Unbinds the named object from the current connection
name | the name to be unbound |
nSecurityException | is thrown if the caller has insufficient permissions |
nChannelNotFoundException | if the channel no longer exists |
nRequestTimedOutException | if the request exceeded the timeout value |
nSessionNotConnectedException | The session is not currently connected to the server |
nUnexpectedResponseException | Received a response from the server for which we can not deal with, see the message for further information |
nIllegalArgumentException | Passed am illegal argument. This means the value passed is outside expected limits |
nNameDoesNotExistException | The name specified does not exist on the server |
nSessionPausedException | The session is currently paused, please resume |