Class ObserverRequestProcessor

All Implemented Interfaces:
Runnable, RequestProcessor

public class ObserverRequestProcessor extends ZooKeeperCriticalThread implements RequestProcessor
This RequestProcessor forwards any requests that modify the state of the system to the Leader.
  • Constructor Details

    • ObserverRequestProcessor

      public ObserverRequestProcessor(ObserverZooKeeperServer zks, RequestProcessor nextProcessor)
      Constructor - takes an ObserverZooKeeperServer to associate with and the next processor to pass requests to after we're finished.
      Parameters:
      zks -
      nextProcessor -
  • Method Details