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.
|
close
String getName()
ThrowingConsumer<Context> select(Context ctx) throws OpProcessorException
OpProcessorException
Copyright © 2013–2016 Apache Software Foundation. All rights reserved.