Class QueueEventStreamDefault

This provides a default implementation of IQueueEventStream.

Inheritance
System.Object
QueueEventStreamDefault
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: PushTechnology.ClientInterface.Client.Features.Control.Clients
Assembly: Diffusion.Client.dll
Syntax
public class QueueEventStreamDefault : IQueueEventStream, IStream, ICallback
Remarks

This simply logs events at debug level and should only be used for diagnostic purposes. This may be extended to implement the notifications you wish to act upon.

Methods

OnClose()

Called if the handler is closed. This happens if the call to register the handler fails, or the handler is unregistered.

Declaration
public virtual void OnClose()

OnError(ErrorReason)

Notification of a contextual error related to this handler. This is analogous to an unchecked exception being raised. Situations in which OnError is called include the session being closed before the handler is registered, a communication timeout, or a problem with the provided parameters. No further calls will be made to this handler.

Declaration
public virtual void OnError(ErrorReason errorReason)
Parameters
Type Name Description
ErrorReason errorReason

A value representing the error; this can be one of the constants defined in ErrorReason, or a feature-specific reason.

OnLowerThresholdCrossed(ISessionId, IMessageQueuePolicy)

The configured lower threshold for a client's queue has been reached.

Declaration
public virtual void OnLowerThresholdCrossed(ISessionId client, IMessageQueuePolicy policy)
Parameters
Type Name Description
ISessionId client

The client session identifier.
IMessageQueuePolicy policy

The message queue policy.

OnUpperThresholdCrossed(ISessionId, IMessageQueuePolicy)

The configured upper queue threshold for a client's queue has been reached.

Declaration
public virtual void OnUpperThresholdCrossed(ISessionId client, IMessageQueuePolicy policy)
Parameters
Type Name Description
ISessionId client

The client session identifier.
IMessageQueuePolicy policy

The message queue policy.

Implements