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

Class NodeRequestProcessor<T extends com.google.protobuf.Message>

java.lang.Object

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

com.alipay.sofa.jraft.rpc.impl.core.NodeRequestProcessor<T>

Type Parameters:

T - Message

All Implemented Interfaces:

RpcProcessor<T>

Direct Known Subclasses:

AppendEntriesRequestProcessor, InstallSnapshotRequestProcessor, ReadIndexRequestProcessor, RequestVoteRequestProcessor, TimeoutNowRequestProcessor

public abstract class NodeRequestProcessor<T extends com.google.protobuf.Message>
extends RpcRequestProcessor<T>

Node handle requests processor template.

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
NodeRequestProcessor(Executor executor, com.google.protobuf.Message defaultResp)

Method Summary

Modifier and Type	Method and Description
protected abstract String	getGroupId(T request)
protected abstract String	getPeerId(T request)
com.google.protobuf.Message	processRequest(T request, RpcRequestClosure done)
protected abstract com.google.protobuf.Message	processRequest0(RaftServerService serviceService, T request, RpcRequestClosure done)

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, interest

Constructor Detail

NodeRequestProcessor

public NodeRequestProcessor(Executor executor,
                            com.google.protobuf.Message defaultResp)

Method Detail

processRequest0

protected abstract com.google.protobuf.Message processRequest0(RaftServerService serviceService,
                                                               T request,
                                                               RpcRequestClosure done)

getPeerId

protected abstract String getPeerId(T request)

getGroupId

protected abstract String getGroupId(T request)

processRequest

public com.google.protobuf.Message processRequest(T request,
                                                  RpcRequestClosure done)

Specified by:

processRequest in class RpcRequestProcessor<T extends com.google.protobuf.Message>