Class QueueEventStreamDefault

Namespace

PushTechnology.ClientInterface.Client.Features.Control.Clients

Assembly

Diffusion.Client.dll

This provides a default implementation of IQueueEventStream.

public class QueueEventStreamDefault : IQueueEventStream, IStream, ICallback

Inheritance

object

QueueEventStreamDefault

Implements

IQueueEventStream

IStream

ICallback

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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.

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.

public virtual void OnError(ErrorReason errorReason)

Parameters

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.

public virtual void OnLowerThresholdCrossed(ISessionId client, IMessageQueuePolicy policy)

Parameters

client ISessionId

The client session identifier.

policy IMessageQueuePolicy

The message queue policy.

OnUpperThresholdCrossed(ISessionId, IMessageQueuePolicy)

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

public virtual void OnUpperThresholdCrossed(ISessionId client, IMessageQueuePolicy policy)

Parameters

client ISessionId

The client session identifier.

policy IMessageQueuePolicy

The message queue policy.