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 org.cometd.bayeux.server.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 java.lang.Object

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

Methods inherited from interface org.cometd.bayeux.server.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