com.sleepycat.je.rep.monitor
Class MonitorService

java.lang.Object
  extended by com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
      extended by com.sleepycat.je.rep.monitor.MonitorService

public class MonitorService
extends ServiceDispatcher.ExecutingService


Nested Class Summary
(package private)  class MonitorService.MonitorServiceRunnable
           
 
Field Summary
static String SERVICE_NAME
           
 
Constructor Summary
MonitorService(Monitor monitor, ServiceDispatcher dispatcher)
           
 
Method Summary
 Runnable getRunnable(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 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 Runnable getRunnable(SocketChannel socketChannel)
Specified by:
getRunnable in class ServiceDispatcher.ExecutingService


Copyright (c) 2004-2012 Oracle. All rights reserved.