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.
|
ThrowingConsumer<Context> |
select(Context ctx)
Given the context (which contains the RequestMessage), return back a Consumer function that will be
executed with the context.
|
closeString getName()
ThrowingConsumer<Context> select(Context ctx) throws OpProcessorException
OpProcessorExceptionCopyright © 2013–2016 Apache Software Foundation. All rights reserved.