public interface OpProcessor extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
String |
getName()
The name of the processor which requests must refer to "processor" field on a request.
|
default void |
init(Settings settings)
Initialize the
OpProcessor with settings from the server. |
ThrowingConsumer<Context> |
select(Context ctx)
Given the context (which contains the RequestMessage), return back a Consumer function that will be
executed with the context.
|
close
String getName()
default void init(Settings settings)
OpProcessor
with settings from the server. This method should only be called once at
server startup by a single thread.ThrowingConsumer<Context> select(Context ctx) throws OpProcessorException
ctx
- OpProcessorException
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.