Package org.cometd.oort
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)
Callback invoked when a message is being published.
-
Constructor Details
-
CloudListener
protected CloudListener()
-
-
Method Details
-
onMessage
Description copied from interface:ServerChannel.MessageListener
Callback invoked when a message is being published.
Implementers can decide to return false to signal that the message should not be published.
- Specified by:
onMessage
in interfaceServerChannel.MessageListener
- Parameters:
from
- the session that publishes the messagechannel
- the channel the message is published tomessage
- the message to be published- Returns:
- whether the message should be published or not
-