org.apache.tinkerpop.gremlin.server.op.control

Class ControlOpProcessor

java.lang.Object

org.apache.tinkerpop.gremlin.server.op.control.ControlOpProcessor

All Implemented Interfaces:

AutoCloseable, OpProcessor

public class ControlOpProcessor
extends Object
implements OpProcessor

Author:

Stephen Mallette (http://stephen.genoprime.com)

Field Summary

Fields

Modifier and Type	Field and Description
static String	OP_PROCESSOR_NAME

Constructor Summary

Constructors

Constructor and Description
ControlOpProcessor()

Method Summary

Modifier and Type	Method and Description
void	close()
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OP_PROCESSOR_NAME

public static final String OP_PROCESSOR_NAME

See Also:

Constant Field Values

Constructor Detail

ControlOpProcessor

public ControlOpProcessor()

Method Detail

getName

public String getName()

Description copied from interface: OpProcessor

The name of the processor which requests must refer to "processor" field on a request.

Specified by:

getName in interface OpProcessor

select

public ThrowingConsumer<Context> select(Context ctx)
                                 throws OpProcessorException

Description copied from interface: OpProcessor

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.

Specified by:

select in interface OpProcessor

Throws:

OpProcessorException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception