com.sleepycat.je.rep.monitor

Class MonitorService

java.lang.Object

com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService

com.sleepycat.je.rep.monitor.MonitorService

public class MonitorService
extends ServiceDispatcher.ExecutingService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	MonitorService.MonitorServiceRunnable

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
MonitorService(Monitor monitor, ServiceDispatcher dispatcher)

Method Summary

Methods

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.

Methods inherited from class com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService

cancel

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SERVICE_NAME

public static final java.lang.String SERVICE_NAME

See Also:

Constant Field Values

Constructor Detail

MonitorService

public MonitorService(Monitor monitor,
              ServiceDispatcher dispatcher)

Method Detail

process

public TextProtocol.ResponseMessage process(Protocol.GroupChange groupChange)

Notify the monitor about the group change (add/remove a node) event.

process

public TextProtocol.ResponseMessage process(Protocol.JoinGroup joinGroup)

Notify the monitor about a node has joined the group.

process

public TextProtocol.ResponseMessage process(Protocol.LeaveGroup leaveGroup)

Notify the monitor about a node has left the group.

getRunnable

public java.lang.Runnable getRunnable(java.nio.channels.SocketChannel socketChannel)

Specified by:

getRunnable in class ServiceDispatcher.ExecutingService