com.pcbsys.nirvana.client.nConstants Class Reference

This class is a container for the various constants that affect the behaviour of various Nirvana Client API calls. More...

Static Public Member Functions

static boolean attemptReconnectAfterAccessChange ()
 Returns whether a nirvana nSession will attempt to reconnect to the realm after the realm ACL has been revoked. More...
 
static boolean attemptReconnectImmediately ()
 Returns whether a nirvana nSession will attempt to immediately reconnect or whether reconnection attempts will back off over time to prevent a network storm where multiple re-connections can occur all at once. More...
 
static void enableDebug (boolean enabled)
 Sets the debug flag to true or false. More...
 
static int getAccessWaitLimit ()
 Returns the outbound publish queue access wait time. More...
 
static int getBlockLimit ()
 Returns the outbound publish queue block wait time. More...
 
static int getConnectionBlockWeighting ()
 Returns the outbound publish queue block weighting. More...
 
static int getConnectionQueueHighWater ()
 Returns the outbound publish queue high watermark. More...
 
static int getConnectionQueueLowWater ()
 Returns the outbound publish queue low watermark. More...
 
static final int getDataGroupQueueSize ()
 
static boolean getEnableAutoGC ()
 The client can enable / disable the um code from monitoring and managing the memory. More...
 
static boolean getEnabledPriorityQueues ()
 Get whether priority queueing is enabled for this client. More...
 
static long getEVENTWAIT ()
 This is the maximum time the client API will wait for a response to a specific request from the Nirvana realm. More...
 
static int getInitialConnectionTimeout ()
 This returns the current value for the Initial socket connect timeout. More...
 
static long getKAWAIT ()
 Retrieves the value in ms to wait before sending a Keep Alive. More...
 
static long getKeepAliveInterval ()
 Gets the value in ms to wait before sending a Keep Alive. More...
 
static int getMaxUnackedEvents ()
 Get the maximum number of events that can be received by a consumer on a shared named object (shared durable) before the consumer need to acknowledge or rollback. More...
 
static int getPriorityQueueCount ()
 Gets the number of queues used for priority messaging. More...
 
static nProxyAuthenticatorHelper getProxyAuthenticatorHelper ()
 Gets the connection helper for proxy connections. More...
 
static int getPushWaitLimit ()
 Returns the outbound publish queue push wait time. More...
 
static long getReconnectInterval ()
 Returns the interval value to use between reconnect attempts when the session is set to reconnect immediately. More...
 
static int getSocketReceiveBufferSize ()
 Get the inbound socket buffer size. More...
 
static int getSocketSendBufferSize ()
 Get the outbound socket buffer size. More...
 
static int getSubHighWater ()
 Retrieves the subscriber queue high watermark. More...
 
static int getSubLowWater ()
 Retrieves the subscriber queue low watermark. More...
 
static int getWriteHandlerType ()
 Returns the current write handling mode that the client is using. More...
 
static void honour3rdPartyCookies (boolean flag)
 If set the underlying nhp(s) drivers will extract and use the Set-Cookie response from an intermediate proxy. More...
 
static boolean isDebugEnabled ()
 Returns whether the debug flag is set to true or false. More...
 
static boolean isHonouring3rdPartyCookies ()
 
static final void resetCertificateAlias ()
 Resets the certificate alias to be used for SSL connections to the one selected by default by the key manager.
 
static void setAccessWaitLimit (int p_accessWait)
 Sets the outbound publish queue access wait time. More...
 
static void setBlockLimit (int p_blockWait)
 Sets the outbound publish queue block wait time. More...
 
static final void setCertificateAlias (String alias)
 Set the certificate alias to be used for SSL connections, overrides the default selection of the key manager. More...
 
static void setClientLogLevel (int level)
 Sets the log level for the client. More...
 
static void setConnectionBlockWeighting (int blockWeighting)
 Sets the outbound publish queue block weighting. More...
 
static void setConnectionQueueHighWater (int high)
 Sets the outbound publish queue high watermark. More...
 
static void setConnectionQueueLowWater (int low)
 Sets the outbound publish queue low watermark. More...
 
static final void setDataGroupQueueSize (int queueSize)
 Sets the number of events that are still to ve delivered to the client. More...
 
static void setDefaultStoreCapacity (int cap)
 Sets the capacity that will be used for any channels or queues created within this JVM. More...
 
static void setDefaultStoreTTL (int ttl)
 Sets the ttl that will be used for any channels or queues created within this JVM. More...
 
static void setEnableAutoGC (boolean flag)
 The client will monitor the memory usage within the JVM, if it exceeds 85% used it will attempt to free memory by calling gc(). More...
 
static void setEnabledPriorityQueues (boolean enabled)
 Enable the usage of priority queues for this client. More...
 
static void setEVENTWAIT (long newval)
 This is the maximum time the client API will wait for a response to a specific request from the Nirvana realm. More...
 
static void setInitialConnectionTimeout (int timeout)
 This sets the current value for the Initial socket connect timeout. More...
 
static void setKAWAIT (long newVal)
 Sets the value in ms to wait before sending a Keep Alive. More...
 
static void setKeepAliveInterval (long newVal)
 Sets the value in ms to wait before sending a Keep Alive. More...
 
static void setMaxUnackedEvents (int maxUnackedEvents)
 Set the maximum number of events that can be received by a consumer on a shared named object (shared durable) before the consumer need to acknowledge or rollback. More...
 
static void setPermittedKeepAlivesMissed (int kas)
 Sets the number of keep alives that the client can miss before closing the connection. More...
 
static void setPriorityQueueCount (int queueCount)
 Sets the number of queues to use when allocating priority. More...
 
static void setProxyAuthenticatorHelper (nProxyAuthenticatorHelper helper)
 Sets the authentication helper for proxy connections. More...
 
static void setPushWaitLimit (int p_pushWait)
 Sets the outbound publish queue push wait time. More...
 
static void setReconnectAfterAccessChange (boolean recon)
 Sets whether a nirvana nSession will attempt to reconnect to the realm after the realm ACL has been revoked. More...
 
static void setReconnectImmediately (boolean recon)
 Sets whether a nirvana nSession will attempt to immediately reconnect or whether reconnection attempts will back off over time to prevent a network storm where multiple re-connections can occur all at once. More...
 
static void setReconnectInterval (long interval)
 Returns the interval value to use between reconnect attempts when the session is set to reconnect immediately. More...
 
static void setSocketReceiveBufferSize (int bufSize)
 Set the inbound socket buffer size. More...
 
static void setSocketSendBufferSize (int bufSize)
 Set the outbound socket buffer size. More...
 
static void setSubHighWater (int high)
 Sets the subscriber queue high watermark. More...
 
static void setSubLowWater (int low)
 Sets the subscriber queue low watermark. More...
 
static final void setWriteHandlerType (int type)
 Allows the client to specify the type of write handling that the client code will employ. More...
 

Static Public Attributes

static final int CHAN_MIXED = com.pcbsys.nirvana.base.nConstants.CHAN_MIXED
 Specifies a mixed (specified on a per event basis) channel type. More...
 
static final int CHAN_MODE_NORMAL = com.pcbsys.nirvana.base.nConstants.CHAN_MODE_NORMAL
 Specifies a channel (or topic) mode for the pub/sub model. More...
 
static final int CHAN_MODE_QUEUE = com.pcbsys.nirvana.base.nConstants.CHAN_MODE_QUEUE
 Specifies a queue (point 2 point) mode for the queue model. More...
 
static final int CHAN_PERSISTENT = com.pcbsys.nirvana.base.nConstants.CHAN_PERSISTENT
 Specifies a persistent (on disk) channel type. More...
 
static final int CHAN_RELIABLE = com.pcbsys.nirvana.base.nConstants.CHAN_RELIABLE
 Specifies a reliable (in memory but with EIDs retained) channel type. More...
 
static final int CHAN_SIMPLE = com.pcbsys.nirvana.base.nConstants.CHAN_SIMPLE
 Specifies a simple (in memory, no EIDs retained) channel type. More...
 
static final int sDirectWriteHandler = fConnectionSettings.sDirectWriteHandler
 This write handler only uses a direct write method to the network layer, this reduces latencies but may increase the cpu used.
 
static final int sQueuedWriteHandler = fConnectionSettings.sBufferedWriteHandler
 This write handler implements the older method of buffering and sending requests and flushing once the queue was emtpy this maximised the network usage but latency can suffer.
 
static final int sStandardWriteHandler = fConnectionSettings.sPeakWriteHandler
 This write handler uses a combination of direct writing and buffered writing to the network depending on client event load.
 

Detailed Description

This class is a container for the various constants that affect the behaviour of various Nirvana Client API calls.

Member Function Documentation

static boolean com.pcbsys.nirvana.client.nConstants.attemptReconnectAfterAccessChange ( )
static

Returns whether a nirvana nSession will attempt to reconnect to the realm after the realm ACL has been revoked.

By default, the nSession will not reconnect after one of these incidents, and a manual restart would need to be initiated

Returns
true if reconnect is enabled after realm ACL subject revocation
static boolean com.pcbsys.nirvana.client.nConstants.attemptReconnectImmediately ( )
static

Returns whether a nirvana nSession will attempt to immediately reconnect or whether reconnection attempts will back off over time to prevent a network storm where multiple re-connections can occur all at once.

Returns
true if reconnect immediately is enabled
static void com.pcbsys.nirvana.client.nConstants.enableDebug ( boolean  enabled)
static

Sets the debug flag to true or false.

If true verbose logging will occur for connections to the realm server

By default, debug is not enabled

Parameters
enabled- whether debug is enabled (true) or disabled (false)
static int com.pcbsys.nirvana.client.nConstants.getAccessWaitLimit ( )
static

Returns the outbound publish queue access wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a period of time that the queue cannot be accessed. This period is called the block access time

Returns
the connection queue access wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static int com.pcbsys.nirvana.client.nConstants.getBlockLimit ( )
static

Returns the outbound publish queue block wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a configurable period. This period is called the block wait time

Returns
the connection queue block wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static int com.pcbsys.nirvana.client.nConstants.getConnectionBlockWeighting ( )
static

Returns the outbound publish queue block weighting.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a configurable period. The connection block weighting is a value that is applied to the block wait value in order to control the frequency of these notifications.

Returns
the connection queue block weighting
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static int com.pcbsys.nirvana.client.nConstants.getConnectionQueueHighWater ( )
static

Returns the outbound publish queue high watermark.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

Returns
the outbound connection queue high water mark
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static int com.pcbsys.nirvana.client.nConstants.getConnectionQueueLowWater ( )
static

Returns the outbound publish queue low watermark.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

Returns
the outbound connection queue low water mark
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static final int com.pcbsys.nirvana.client.nConstants.getDataGroupQueueSize ( )
static
Returns
The current data group event queue size
static boolean com.pcbsys.nirvana.client.nConstants.getEnableAutoGC ( )
static

The client can enable / disable the um code from monitoring and managing the memory.

Returns
a boolean flag indicating the current state
static boolean com.pcbsys.nirvana.client.nConstants.getEnabledPriorityQueues ( )
static

Get whether priority queueing is enabled for this client.

Returns
true if priority queueing is enabled for this client, false otherwise.
static long com.pcbsys.nirvana.client.nConstants.getEVENTWAIT ( )
static

This is the maximum time the client API will wait for a response to a specific request from the Nirvana realm.

The default value is 60 secs and typically if you get a nRequestTimedOutException the cause would be:

  1. There is a protocol mismatch between the client library in use and server you are connected to.
  1. The realm is really so busy that has not managed to respond to your request within the specified maximum interval.
Returns
a long specifying the maximum wait time for a protocol request (in ms)
static int com.pcbsys.nirvana.client.nConstants.getInitialConnectionTimeout ( )
static

This returns the current value for the Initial socket connect timeout.

This timeout is specified in the actual underlying Socket connect, and enables connections made to non existent or unreachable hosts to be returned within a configurable timeframe, rather than relying on the underlying JVM and OS timeout value

Returns
the socket connect timeout value, default is 30000ms
static long com.pcbsys.nirvana.client.nConstants.getKAWAIT ( )
static

Retrieves the value in ms to wait before sending a Keep Alive.

Returns
a long specifiying the keep alive wait time in ms
Deprecated:
static long com.pcbsys.nirvana.client.nConstants.getKeepAliveInterval ( )
static

Gets the value in ms to wait before sending a Keep Alive.

This is relevant to the local JVM only.

static int com.pcbsys.nirvana.client.nConstants.getMaxUnackedEvents ( )
static

Get the maximum number of events that can be received by a consumer on a shared named object (shared durable) before the consumer need to acknowledge or rollback.

The default value is 10.

static int com.pcbsys.nirvana.client.nConstants.getPriorityQueueCount ( )
static

Gets the number of queues used for priority messaging.

If priority messaging is disabled, this method will return 0.

Returns
The number of queues used for priority messaging. This value is between 0 and 10.
static nProxyAuthenticatorHelper com.pcbsys.nirvana.client.nConstants.getProxyAuthenticatorHelper ( )
static

Gets the connection helper for proxy connections.

This will return the last value passed to setProxyAuthenticatorHelper

Returns
nProxyAuthenticatorHelper the helper for proxy connections.
static int com.pcbsys.nirvana.client.nConstants.getPushWaitLimit ( )
static

Returns the outbound publish queue push wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a period of time that events cannot be pushed to the queue. This period is called the push wait time

Returns
the connection queue push wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static long com.pcbsys.nirvana.client.nConstants.getReconnectInterval ( )
static

Returns the interval value to use between reconnect attempts when the session is set to reconnect immediately.

Returns
true if reconnect immediately is enabled
Since
4.0
static int com.pcbsys.nirvana.client.nConstants.getSocketReceiveBufferSize ( )
static

Get the inbound socket buffer size.

Returns
the size in bytes for the inbound buffer size
static int com.pcbsys.nirvana.client.nConstants.getSocketSendBufferSize ( )
static

Get the outbound socket buffer size.

Returns
the size in bytes for the outbound buffer size
static int com.pcbsys.nirvana.client.nConstants.getSubHighWater ( )
static

Retrieves the subscriber queue high watermark.

Each Nirvana subscriber uses a queue to store events retrieved from the server prior to performing the callback to the registered event listeners. When the queue reaches the high watermark the subscription is suspended to allow the event listener to catch up and control the amount of memory used on the client. When the queue reaches the low watermark, the subscription is automatically resumed.

Returns
an int specifiying the number of events to be used as a queue high watermark
static int com.pcbsys.nirvana.client.nConstants.getSubLowWater ( )
static

Retrieves the subscriber queue low watermark.

Each Nirvana subscriber uses a queue to store events retrieved from the server prior to performing the callback to the registered event listeners. When the queue reaches the high watermark the subscription is suspended to allow the event listener to catch up and control the amount of memory used on the client. When the queue reaches the low watermark, the subscription is automatically resumed.

Returns
an int specifiying the number of events to be used as a queue low watermark
static int com.pcbsys.nirvana.client.nConstants.getWriteHandlerType ( )
static

Returns the current write handling mode that the client is using.

Returns
an int of either sStandardWriteHandler or sDirectWriteHandler
static void com.pcbsys.nirvana.client.nConstants.honour3rdPartyCookies ( boolean  flag)
static

If set the underlying nhp(s) drivers will extract and use the Set-Cookie response from an intermediate proxy.

Useful for load balancers

Parameters
flag- Enable or Disable the use of the HTTP Cookie header
static boolean com.pcbsys.nirvana.client.nConstants.isDebugEnabled ( )
static

Returns whether the debug flag is set to true or false.

By default, debug is not enabled

Returns
whether debug is enabled (true) or disabled (false)
static boolean com.pcbsys.nirvana.client.nConstants.isHonouring3rdPartyCookies ( )
static
Returns
the current state of the http cookie header use
static void com.pcbsys.nirvana.client.nConstants.setAccessWaitLimit ( int  p_accessWait)
static

Sets the outbound publish queue access wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a period of time that the queue cannot be accessed. This period is called the block access time

Parameters
p_accessWaitthe connection queue access wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static void com.pcbsys.nirvana.client.nConstants.setBlockLimit ( int  p_blockWait)
static

Sets the outbound publish queue block wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a configurable period. This period is called the block wait time

Parameters
p_blockWaitthe connection queue block wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static final void com.pcbsys.nirvana.client.nConstants.setCertificateAlias ( String  alias)
static

Set the certificate alias to be used for SSL connections, overrides the default selection of the key manager.

If the specified alias is not found, the standrd key manager selection is used instead.

Parameters
aliasthe alias name of the certificate to be used
static void com.pcbsys.nirvana.client.nConstants.setClientLogLevel ( int  level)
static

Sets the log level for the client.

All Nirvana client api code contains useful logging messages. The messages are set at specific levels from 0-7. This methid allows you to choose what log level you wish to see. Setting to log level 0 will provide verbose output, whereas level 7 will be fairly quiet.

By default, these messages will be sent to System.out

Parameters
levelthe log level you wish to set the client application to for nirvana messages
static void com.pcbsys.nirvana.client.nConstants.setConnectionBlockWeighting ( int  blockWeighting)
static

Sets the outbound publish queue block weighting.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a configurable period. The connection block weighting is a value that is applied to the block wait value in order to control the frequency of these notifications.

Parameters
blockWeightingthe connection queue block weighting
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static void com.pcbsys.nirvana.client.nConstants.setConnectionQueueHighWater ( int  high)
static

Sets the outbound publish queue high watermark.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

Parameters
highthe outbound connection queue high water mark
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static void com.pcbsys.nirvana.client.nConstants.setConnectionQueueLowWater ( int  low)
static

Sets the outbound publish queue low watermark.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

Parameters
lowthe outbound connection queue low water mark
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static final void com.pcbsys.nirvana.client.nConstants.setDataGroupQueueSize ( int  queueSize)
static

Sets the number of events that are still to ve delivered to the client.

Parameters
queueSizenumber of events that the queue will hold before blocking
static void com.pcbsys.nirvana.client.nConstants.setDefaultStoreCapacity ( int  cap)
static

Sets the capacity that will be used for any channels or queues created within this JVM.

Parameters
capthe capacity to set on the channels / queues
static void com.pcbsys.nirvana.client.nConstants.setDefaultStoreTTL ( int  ttl)
static

Sets the ttl that will be used for any channels or queues created within this JVM.

Parameters
ttlthe ttl to set on the channels / queues
static void com.pcbsys.nirvana.client.nConstants.setEnableAutoGC ( boolean  flag)
static

The client will monitor the memory usage within the JVM, if it exceeds 85% used it will attempt to free memory by calling gc().

If this is not required then, by calling this function, this behaviour is disabled.

Please note that the memory management and OOME that may arise needs to be handled by the client.

Parameters
flag- boolean flag indicating the required functionality
static void com.pcbsys.nirvana.client.nConstants.setEnabledPriorityQueues ( boolean  enabled)
static

Enable the usage of priority queues for this client.

This will give delivery preference to messages marked high priority for this client.

Parameters
enabledboolean true will enable priority queueing for this client, false will disable it.
static void com.pcbsys.nirvana.client.nConstants.setEVENTWAIT ( long  newval)
static

This is the maximum time the client API will wait for a response to a specific request from the Nirvana realm.

The default value is 60 secs and typically if you get a nRequestTimedOutException the cause would be:

  1. There is a protocol mismatch between the client library in use and server you are connected to.
  1. The realm is really so busy that has not managed to respond to your request within the specified maximum interval.

Calling this method will only have effect on the local JVM. Alternatively if you change this value through on the realm configuration using the Admin API, all subsequent Nirvana clients that connect will be affected.

static void com.pcbsys.nirvana.client.nConstants.setInitialConnectionTimeout ( int  timeout)
static

This sets the current value for the Initial socket connect timeout.

This timeout is specified in the actual underlying Socket connect, and enables connections made to non existent or unreachable hosts to be returned within a configurable timeframe.

Parameters
timeoutthe socket connect timeout value to be set, default is 30000ms
static void com.pcbsys.nirvana.client.nConstants.setKAWAIT ( long  newVal)
static

Sets the value in ms to wait before sending a Keep Alive.

This is applied to the local JVM only and is NOT sent to the realm.

Deprecated:
static void com.pcbsys.nirvana.client.nConstants.setKeepAliveInterval ( long  newVal)
static

Sets the value in ms to wait before sending a Keep Alive.

This is applied to the local JVM only and is NOT sent to the realm.

static void com.pcbsys.nirvana.client.nConstants.setMaxUnackedEvents ( int  maxUnackedEvents)
static

Set the maximum number of events that can be received by a consumer on a shared named object (shared durable) before the consumer need to acknowledge or rollback.

The default value is 10.

Parameters
maxUnackedEventsthe maximum number of events that a consumer can have unacknowledged at one time
static void com.pcbsys.nirvana.client.nConstants.setPermittedKeepAlivesMissed ( int  kas)
static

Sets the number of keep alives that the client can miss before closing the connection.

If 0, the client does not check for any missed keep alives from the server and will continue sending its own keep alive events, until the connection is detected as lost. If > 0, say 1, when the client has not received a message for 1 X the KeepAlive time + 20000ms, the underlying connection will be closed by the client and reconnection will be attempted.

Parameters
kasNumber of keep alive messages the client will miss before determining the connection as broken
static void com.pcbsys.nirvana.client.nConstants.setPriorityQueueCount ( int  queueCount)
static

Sets the number of queues to use when allocating priority.

This can be a number between 1 and 10. The number of queues control how priority is arranged, smaller queue counts will coalese priority bands. For example, a queue count of 5 will result in priority 1 and 2, 3 and 4, 5 and 6, 7 and 8, 9 and 10 grouped together.

Parameters
queueCountThe number of queues to use for priority allocation
Exceptions
IllegalArgumentExceptionif the supplied integer is not between 1 and 10, then this method will throw an IllegalArgumentException
static void com.pcbsys.nirvana.client.nConstants.setProxyAuthenticatorHelper ( nProxyAuthenticatorHelper  helper)
static

Sets the authentication helper for proxy connections.

Parameters
helperThe helper to use for proxy connections.
static void com.pcbsys.nirvana.client.nConstants.setPushWaitLimit ( int  p_pushWait)
static

Sets the outbound publish queue push wait time.

Each Nirvana session that sends events to the server (e.g. publishers) place events into an outbound queue to be sent to the server. When the queue reaches the high watermark the queue is unavailable to the client session until the queue reaches it's low water mark, i.e. the events are delivered to the server. When the low water mark is reached the queue is automatically resumed.

When an outbound queue becomes blocked (unavailable) it is possible to become notified after a period of time that events cannot be pushed to the queue. This period is called the push wait time

Parameters
p_pushWaitthe connection queue push wait
See Also
com.pcbsys.nirvana.client.nConnectionQueueListener
static void com.pcbsys.nirvana.client.nConstants.setReconnectAfterAccessChange ( boolean  recon)
static

Sets whether a nirvana nSession will attempt to reconnect to the realm after the realm ACL has been revoked.

By default, the nSession will not reconnect after one of these incidents, and a manual restart would need to be initiated

Parameters
recontrue - will reconnect continually until successful, false, will disabled reconnect
static void com.pcbsys.nirvana.client.nConstants.setReconnectImmediately ( boolean  recon)
static

Sets whether a nirvana nSession will attempt to immediately reconnect or whether reconnection attempts will back off over time to prevent a network storm where multiple re-connections can occur all at once.

Parameters
recontrue - will reconnect immediately, and use the value set in
Since
4.0
static void com.pcbsys.nirvana.client.nConstants.setReconnectInterval ( long  interval)
static

Returns the interval value to use between reconnect attempts when the session is set to reconnect immediately.

Parameters
intervalvalue in milliseconds specifying the interval between reconnect attempts
Since
4.0
static void com.pcbsys.nirvana.client.nConstants.setSocketReceiveBufferSize ( int  bufSize)
static

Set the inbound socket buffer size.

Parameters
bufSizethe size in bytes for the inbound buffer size
static void com.pcbsys.nirvana.client.nConstants.setSocketSendBufferSize ( int  bufSize)
static

Set the outbound socket buffer size.

Parameters
bufSizethe size in bytes for the outbound buffer size
static void com.pcbsys.nirvana.client.nConstants.setSubHighWater ( int  high)
static

Sets the subscriber queue high watermark.

Each Nirvana subscriber uses a queue to store events retrieved from the server prior to performing the callback to the registered event listeners. When the queue reaches the high watermark the subscription is suspended to allow the event listener to catch up and control the amount of memory used on the client. When the queue reaches the low watermark, the subscription is automatically resumed.

Parameters
highsets the subscriber high water mark
static void com.pcbsys.nirvana.client.nConstants.setSubLowWater ( int  low)
static

Sets the subscriber queue low watermark.

Each Nirvana subscriber uses a queue to store events retrieved from the server prior to performing the callback to the registered event listeners. When the queue reaches the high watermark the subscription is suspended to allow the event listener to catch up and control the amount of memory used on the client. When the queue reaches the low watermark, the subscription is automatically resumed.

Parameters
lowthe low water ,ark for the subscriber
static final void com.pcbsys.nirvana.client.nConstants.setWriteHandlerType ( int  type)
static

Allows the client to specify the type of write handling that the client code will employ.

Please note this needs to be set prior to any nSession creation.

Parameters
typesStandardWriteHandler, sQueuedWriteHandler or sDirectWriteHandler

Field Documentation

final int com.pcbsys.nirvana.client.nConstants.CHAN_MIXED = com.pcbsys.nirvana.base.nConstants.CHAN_MIXED
static

Specifies a mixed (specified on a per event basis) channel type.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.MIXED_TYPE
final int com.pcbsys.nirvana.client.nConstants.CHAN_MODE_NORMAL = com.pcbsys.nirvana.base.nConstants.CHAN_MODE_NORMAL
static

Specifies a channel (or topic) mode for the pub/sub model.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.CHANNEL_MODE
final int com.pcbsys.nirvana.client.nConstants.CHAN_MODE_QUEUE = com.pcbsys.nirvana.base.nConstants.CHAN_MODE_QUEUE
static

Specifies a queue (point 2 point) mode for the queue model.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.QUEUE_MODE
final int com.pcbsys.nirvana.client.nConstants.CHAN_PERSISTENT = com.pcbsys.nirvana.base.nConstants.CHAN_PERSISTENT
static

Specifies a persistent (on disk) channel type.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.PERSISTENT_TYPE
final int com.pcbsys.nirvana.client.nConstants.CHAN_RELIABLE = com.pcbsys.nirvana.base.nConstants.CHAN_RELIABLE
static

Specifies a reliable (in memory but with EIDs retained) channel type.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.RELIABLE_TYPE
final int com.pcbsys.nirvana.client.nConstants.CHAN_SIMPLE = com.pcbsys.nirvana.base.nConstants.CHAN_SIMPLE
static

Specifies a simple (in memory, no EIDs retained) channel type.

See Also
nChannelAttributes
Deprecated:
As of version 2.0, please use nChannelAttributes.SIMPLE_TYPE