public class MonitorService extends ServiceDispatcher.ExecutingService
Modifier and Type | Class and Description |
---|---|
(package private) class |
MonitorService.MonitorServiceRunnable |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SERVICE_NAME |
Constructor and Description |
---|
MonitorService(Monitor monitor,
ServiceDispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
java.lang.Runnable |
getRunnable(java.nio.channels.SocketChannel socketChannel) |
TextProtocol.ResponseMessage |
process(Protocol.GroupChange groupChange)
Notify the monitor about the group change (add/remove a node) event.
|
TextProtocol.ResponseMessage |
process(Protocol.JoinGroup joinGroup)
Notify the monitor about a node has joined the group.
|
TextProtocol.ResponseMessage |
process(Protocol.LeaveGroup leaveGroup)
Notify the monitor about a node has left the group.
|
cancel
public static final java.lang.String SERVICE_NAME
public MonitorService(Monitor monitor, ServiceDispatcher dispatcher)
public TextProtocol.ResponseMessage process(Protocol.GroupChange groupChange)
public TextProtocol.ResponseMessage process(Protocol.JoinGroup joinGroup)
public TextProtocol.ResponseMessage process(Protocol.LeaveGroup leaveGroup)
public java.lang.Runnable getRunnable(java.nio.channels.SocketChannel socketChannel)
getRunnable
in class ServiceDispatcher.ExecutingService
Copyright (c) 2004-2012 Oracle. All rights reserved.