public class MonitorService
extends com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
MonitorService(Monitor monitor,
com.sleepycat.je.rep.utilint.ServiceDispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
Runnable |
getRunnable(SocketChannel socketChannel) |
com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage |
process(Protocol.GroupChange groupChange)
Notify the monitor about the group change (add/remove a node) event.
|
com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage |
process(Protocol.JoinGroup joinGroup)
Notify the monitor about a node has joined the group.
|
com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage |
process(Protocol.LeaveGroup leaveGroup)
Notify the monitor about a node has left the group.
|
public static final String SERVICE_NAME
public MonitorService(Monitor monitor, com.sleepycat.je.rep.utilint.ServiceDispatcher dispatcher)
public com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage process(Protocol.GroupChange groupChange)
public com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage process(Protocol.JoinGroup joinGroup)
public com.sleepycat.je.rep.impl.TextProtocol.ResponseMessage process(Protocol.LeaveGroup leaveGroup)
public Runnable getRunnable(SocketChannel socketChannel)
getRunnable
in class com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
Copyright (c) 2004, 2013 Oracle and/or its affiliates. All rights reserved.