com.alipay.sofa.jraft.rpc.impl.core

Class TimeoutNowRequestProcessor

java.lang.Object

com.alipay.sofa.jraft.rpc.RpcRequestProcessor<T>

com.alipay.sofa.jraft.rpc.impl.core.NodeRequestProcessor<RpcRequests.TimeoutNowRequest>

com.alipay.sofa.jraft.rpc.impl.core.TimeoutNowRequestProcessor

All Implemented Interfaces:

RpcProcessor<RpcRequests.TimeoutNowRequest>

public class TimeoutNowRequestProcessor
extends NodeRequestProcessor<RpcRequests.TimeoutNowRequest>

TimeoutNow request processor.

Author:

boyan (boyan@alibaba-inc.com), jiachun.fjc

Nested Class Summary

Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.rpc.RpcProcessor

RpcProcessor.ExecutorSelector

Field Summary

Fields inherited from class com.alipay.sofa.jraft.rpc.RpcRequestProcessor

LOG

Constructor Summary

Constructors

Constructor and Description
TimeoutNowRequestProcessor(Executor executor)

Method Summary

Modifier and Type	Method and Description
protected String	getGroupId(RpcRequests.TimeoutNowRequest request)
protected String	getPeerId(RpcRequests.TimeoutNowRequest request)
String	interest() The class name of user request.
com.google.protobuf.Message	processRequest0(RaftServerService service, RpcRequests.TimeoutNowRequest request, RpcRequestClosure done)

Methods inherited from class com.alipay.sofa.jraft.rpc.impl.core.NodeRequestProcessor

processRequest

Methods inherited from class com.alipay.sofa.jraft.rpc.RpcRequestProcessor

defaultResp, executor, handleRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alipay.sofa.jraft.rpc.RpcProcessor

executorSelector

Constructor Detail

TimeoutNowRequestProcessor

public TimeoutNowRequestProcessor(Executor executor)

Method Detail

getPeerId

protected String getPeerId(RpcRequests.TimeoutNowRequest request)

Specified by:

getPeerId in class NodeRequestProcessor<RpcRequests.TimeoutNowRequest>

getGroupId

protected String getGroupId(RpcRequests.TimeoutNowRequest request)

Specified by:

getGroupId in class NodeRequestProcessor<RpcRequests.TimeoutNowRequest>

processRequest0

public com.google.protobuf.Message processRequest0(RaftServerService service,
                                                   RpcRequests.TimeoutNowRequest request,
                                                   RpcRequestClosure done)

Specified by:

processRequest0 in class NodeRequestProcessor<RpcRequests.TimeoutNowRequest>

interest

public String interest()

Description copied from interface: RpcProcessor

The class name of user request. Use String type to avoid loading class.

Returns:

interested request's class name