Package com.pushtechnology.diffusion.client.features.control.clients

Class ClientControl.QueueEventStream.Default

java.lang.Object

com.pushtechnology.diffusion.client.callbacks.Callback.Default

com.pushtechnology.diffusion.client.callbacks.Stream.Default

com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream.Default

All Implemented Interfaces:

Callback, Stream, ClientControl.QueueEventStream

Enclosing interface:

ClientControl.QueueEventStream

public static class ClientControl.QueueEventStream.Default
extends Stream.Default
implements ClientControl.QueueEventStream

This provides a default implementation of ClientControl.QueueEventStream.

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.

Nested Class Summary

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.callbacks.Callback

Callback.Default

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream

ClientControl.QueueEventStream.Default

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.callbacks.Stream

Stream.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	onLowerThresholdCrossed(SessionId sessionId, MessageQueuePolicy policy)	The configured lower threshold for a client's queue has been reached.
void	onUpperThresholdCrossed(SessionId sessionId, MessageQueuePolicy policy)	The configured upper threshold for a client's queue has been reached.

Methods inherited from class com.pushtechnology.diffusion.client.callbacks.Stream.Default

onClose

Methods inherited from class com.pushtechnology.diffusion.client.callbacks.Callback.Default

onError

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.pushtechnology.diffusion.client.callbacks.Callback

onError

Methods inherited from interface com.pushtechnology.diffusion.client.callbacks.Stream

onClose

Constructor Details

Default

public Default()

Method Details

onUpperThresholdCrossed

public void onUpperThresholdCrossed(SessionId sessionId,
 MessageQueuePolicy policy)

Description copied from interface: ClientControl.QueueEventStream

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

Specified by:

onUpperThresholdCrossed in interface ClientControl.QueueEventStream

Parameters:

sessionId - the client session identifier

policy - the message queue policy

onLowerThresholdCrossed

public void onLowerThresholdCrossed(SessionId sessionId,
 MessageQueuePolicy policy)

Description copied from interface: ClientControl.QueueEventStream

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

Specified by:

onLowerThresholdCrossed in interface ClientControl.QueueEventStream

Parameters:

sessionId - the client session identifier

policy - the message queue policy