public class ChannelRegistrationProtocol extends Object implements Protocol<DiscoveryMessage>
| Constructor and Description |
|---|
ChannelRegistrationProtocol(MessageOriginator messageOriginator) |
| Modifier and Type | Method and Description |
|---|---|
void |
handleIncoming(DiscoveryMessage message)
Handles an incoming message.
|
void |
handleOutgoing(DiscoveryMessage message)
Handles an outgoing message.
|
void |
start(ProtocolContext<DiscoveryMessage> context)
Called to initialise the protocol.
|
void |
stopRequested()
Requests that this protocol initiate its stop messages.
|
public ChannelRegistrationProtocol(MessageOriginator messageOriginator)
public void start(ProtocolContext<DiscoveryMessage> context)
Protocolstart in interface Protocol<DiscoveryMessage>context - The context.public void handleIncoming(DiscoveryMessage message)
ProtocolhandleIncoming in interface Protocol<DiscoveryMessage>public void handleOutgoing(DiscoveryMessage message)
ProtocolhandleOutgoing in interface Protocol<DiscoveryMessage>public void stopRequested()
ProtocolProtocolContext.stopLater() to defer stop until some
messages are received. In which case, it should later call ProtocolContext.stopped() to indicate it has finished.
If the protocol does not call stopLater(), it is assumed to have stopped when this method returns.stopRequested in interface Protocol<DiscoveryMessage>Copyright © 2013. All rights reserved