public class SessionOpProcessor extends AbstractEvalOpProcessor
OpProcessor implementation that handles
 ScriptEngine script evaluation in the context of a session. Note that this processor will
 also take a "close" op to kill the session and rollback any incomplete transactions.AbstractEvalOpProcessor.BindingSupplier<T>| Modifier and Type | Field and Description | 
|---|---|
| static String | CONFIG_SESSION_TIMEOUTConfiguration setting for how long a session will be available before it timesout. | 
| static long | DEFAULT_SESSION_TIMEOUTDefault timeout for a session is eight hours. | 
| static String | OP_PROCESSOR_NAME | 
| protected static ConcurrentHashMap<String,Session> | sessionsScript engines are evaluated in a per session context where imports/scripts are isolated per session. | 
evalOpTimer, manageTransactions| Constructor and Description | 
|---|
| SessionOpProcessor() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | close() | 
| protected void | evalOp(Context context) | 
| ThrowingConsumer<Context> | getEvalOp()Provides an operation for evaluating a Gremlin script. | 
| String | getName()The name of the processor which requests must refer to "processor" field on a request. | 
| protected static Session | getSession(Context context,
          RequestMessage msg)Examines the  RequestMessageand extracts the session token. | 
| Optional<ThrowingConsumer<Context>> | selectOther(RequestMessage requestMessage)Session based requests accept a "close" operator in addition to "eval". | 
| protected Optional<ThrowingConsumer<Context>> | validateEvalMessage(RequestMessage message) | 
evalOpInternal, handleIterator, selectpublic static final String OP_PROCESSOR_NAME
protected static ConcurrentHashMap<String,Session> sessions
public static final String CONFIG_SESSION_TIMEOUT
public static final long DEFAULT_SESSION_TIMEOUT
public String getName()
OpProcessorpublic Optional<ThrowingConsumer<Context>> selectOther(RequestMessage requestMessage) throws OpProcessorException
selectOther in class AbstractEvalOpProcessorOpProcessorExceptionpublic ThrowingConsumer<Context> getEvalOp()
AbstractEvalOpProcessorgetEvalOp in class AbstractEvalOpProcessorprotected Optional<ThrowingConsumer<Context>> validateEvalMessage(RequestMessage message) throws OpProcessorException
validateEvalMessage in class AbstractEvalOpProcessorOpProcessorExceptionprotected void evalOp(Context context) throws OpProcessorException
OpProcessorExceptionprotected static Session getSession(Context context, RequestMessage msg)
RequestMessage and extracts the session token. The session is then either found or a new
 one is created.Copyright © 2013–2015 Apache Software Foundation. All rights reserved.