Class Oort.CloudListener

java.lang.Object

org.cometd.oort.Oort.CloudListener

All Implemented Interfaces:

EventListener, Bayeux.BayeuxListener, ConfigurableServerChannel.ServerChannelListener, ServerChannel.MessageListener

Enclosing class:

Oort

protected class Oort.CloudListener
extends Object
implements ServerChannel.MessageListener

This listener handles messages sent to /oort/cloud that contains the list of comets connected to the Oort that just joined the cloud.

For example, if comets A and B are connected, and if comets C and D are connected, when connecting A and C, a message is sent from A to C on /oort/cloud containing the comets connected to A (in this case B). When C receives this message, it knows it has to connect to B also.

Nested Class Summary

Nested classes/interfaces inherited from interface ConfigurableServerChannel.ServerChannelListener

ConfigurableServerChannel.ServerChannelListener.Weak

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CloudListener()

Method Summary

Modifier and Type	Method	Description
boolean	onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)	Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).

Methods inherited from class Object

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

Methods inherited from interface ServerChannel.MessageListener

onMessage

Constructor Details

CloudListener

protected CloudListener()

Method Details

onMessage

public boolean onMessage(ServerSession from,
 ServerChannel channel,
 ServerMessage.Mutable message)

Description copied from interface: ServerChannel.MessageListener

Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).

Specified by:

onMessage in interface ServerChannel.MessageListener

Parameters:

from - the session that publishes the message

channel - the channel the message is published to

message - the message to be published

Returns:

whether the message processing should continue