public class MonitorService
extends com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
Modifier and Type | Field and Description |
---|---|
static com.sleepycat.je.utilint.TestHook<GroupChangeEvent> |
processGroupChangeHook |
static com.sleepycat.je.utilint.TestHook<JoinGroupEvent> |
processJoinGroupHook |
static com.sleepycat.je.utilint.TestHook<LeaveGroupEvent> |
processLeaveGroupHook |
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(com.sleepycat.je.rep.net.DataChannel dataChannel) |
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 volatile com.sleepycat.je.utilint.TestHook<GroupChangeEvent> processGroupChangeHook
public static volatile com.sleepycat.je.utilint.TestHook<JoinGroupEvent> processJoinGroupHook
public static volatile com.sleepycat.je.utilint.TestHook<LeaveGroupEvent> processLeaveGroupHook
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(com.sleepycat.je.rep.net.DataChannel dataChannel)
getRunnable
in class com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
Copyright (c) 2002, 2015 Oracle and/or its affiliates. All rights reserved.