Interface OpProcessor

    • Method Detail

      • getName

        String getName()
        The name of the processor which requests must refer to "processor" field on a request.
      • init

        default void init​(Settings settings)
        Initialize the OpProcessor with settings from the server. This method should only be called once at server startup by a single thread.
      • select

        ThrowingConsumer<Context> select​(Context ctx)
                                  throws OpProcessorException
        Given the context (which contains the RequestMessage), return back a Consumer function that will be executed with the context. A typical implementation will simply check the "op" field on the RequestMessage and return the Consumer function for that particular operation.
        ctx -