Package com.kodexa.client.remote

Class AbstractKodexaSession

java.lang.Object

com.kodexa.client.remote.AbstractKodexaConnection

com.kodexa.client.remote.AbstractKodexaSession

Direct Known Subclasses:

RemoteAction, RemotePipelineSession

public abstract class AbstractKodexaSession
extends AbstractKodexaConnection

Abstract base for both Cloud Service and Cloud Pipelines in Kodexa

Field Summary

Fields inherited from class com.kodexa.client.remote.AbstractKodexaConnection

jsonOm, messagePackOm

Constructor Summary

Constructors

Constructor	Description
AbstractKodexaSession(String ref)

Method Summary

Modifier and Type	Method	Description
protected CloudSession	createSession(CloudSessionType sessionType)
CloudExecution	executeService(CloudSession session, Document document, PipelineContext context, Options options, Map<String,Object> parameters)	Execute the service in Kodexa
Document	getOutputDocument(CloudSession session, CloudExecution execution)
String	getRef()
TableStore	getTableStore(CloudSession session, CloudExecution execution, CloudStore cloudStore)
void	mergeStores(CloudSession session, CloudExecution execution, PipelineContext pipelineContext)
protected CloudExecution	waitForExecution(CloudSession session, CloudExecution execution)

Methods inherited from class com.kodexa.client.remote.AbstractKodexaConnection

getRequestConfig

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractKodexaSession

public AbstractKodexaSession(String ref)

Method Detail

getTableStore

public TableStore getTableStore(CloudSession session,
                                CloudExecution execution,
                                CloudStore cloudStore)

getOutputDocument

public Document getOutputDocument(CloudSession session,
                                  CloudExecution execution)

mergeStores

public void mergeStores(CloudSession session,
                        CloudExecution execution,
                        PipelineContext pipelineContext)

waitForExecution

protected CloudExecution waitForExecution(CloudSession session,
                                          CloudExecution execution)

createSession

protected CloudSession createSession(CloudSessionType sessionType)

executeService

public CloudExecution executeService(CloudSession session,
                                     Document document,
                                     PipelineContext context,
                                     Options options,
                                     Map<String,Object> parameters)

Execute the service in Kodexa

Parameters:

session - The session to use

document - The document to send

context - The context for the pipeline

options - The options for the execution

parameters - the parameters to pass to this pipeline

Returns:

An instance of a cloud execution

getRef

public String getRef()