Class ProposalRequestProcessor
- java.lang.Object
-
- org.apache.zookeeper.server.quorum.ProposalRequestProcessor
-
- All Implemented Interfaces:
RequestProcessor
public class ProposalRequestProcessor extends Object implements RequestProcessor
This RequestProcessor simply forwards requests to an AckRequestProcessor and SyncRequestProcessor.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.server.RequestProcessor
RequestProcessor.RequestProcessorException
-
-
Field Summary
Fields Modifier and Type Field Description static String
FORWARD_LEARNER_REQUESTS_TO_COMMIT_PROCESSOR_DISABLED
-
Constructor Summary
Constructors Constructor Description ProposalRequestProcessor(LeaderZooKeeperServer zks, RequestProcessor nextProcessor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
initialize()
initialize this processorvoid
processRequest(Request request)
void
shutdown()
-
-
-
Field Detail
-
FORWARD_LEARNER_REQUESTS_TO_COMMIT_PROCESSOR_DISABLED
public static final String FORWARD_LEARNER_REQUESTS_TO_COMMIT_PROCESSOR_DISABLED
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ProposalRequestProcessor
public ProposalRequestProcessor(LeaderZooKeeperServer zks, RequestProcessor nextProcessor)
-
-
Method Detail
-
initialize
public void initialize()
initialize this processor
-
processRequest
public void processRequest(Request request) throws RequestProcessor.RequestProcessorException
- Specified by:
processRequest
in interfaceRequestProcessor
- Throws:
RequestProcessor.RequestProcessorException
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceRequestProcessor
-
-