com.sleepycat.je.rep.utilint

Class ServiceDispatcher.ExecutingRunnable

java.lang.Object

com.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingRunnable

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

GroupService.GroupServiceRunnable, MonitorService.MonitorServiceRunnable, NodeStateService.NodeStateServiceRunnable

Enclosing class:

ServiceDispatcher

public abstract static class ServiceDispatcher.ExecutingRunnable
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.channels.SocketChannel	channel
protected boolean	expectResponse
protected TextProtocol	protocol

Constructor Summary

Constructors

Constructor and Description
ExecutingRunnable(java.nio.channels.SocketChannel channel, TextProtocol protocol, boolean expectResponse)

Method Summary

Modifier and Type	Method and Description
protected abstract TextProtocol.ResponseMessage	getResponse(TextProtocol.RequestMessage request)
protected abstract void	logMessage(java.lang.String message)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected final java.nio.channels.SocketChannel channel

protocol

protected final TextProtocol protocol

expectResponse

protected final boolean expectResponse

Constructor Detail

ExecutingRunnable

public ExecutingRunnable(java.nio.channels.SocketChannel channel,
                         TextProtocol protocol,
                         boolean expectResponse)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

getResponse

protected abstract TextProtocol.ResponseMessage getResponse(TextProtocol.RequestMessage request)
                                                     throws java.io.IOException

Throws:

java.io.IOException

logMessage

protected abstract void logMessage(java.lang.String message)