Package com.eka.middleware.service

Class RuntimePipeline

java.lang.Object

com.eka.middleware.service.RuntimePipeline

public class RuntimePipeline
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final DataPipeline	dataPipeLine
final Map<String,Object>	payload

Constructor Summary

Constructors

Constructor	Description
RuntimePipeline(Tenant tenant, String requestId, String correlationId, io.undertow.server.HttpServerExchange exchange, String resource, String urlPath)

Method Summary

Modifier and Type	Method	Description
static RuntimePipeline	create(Tenant tenant, String requestId, String correlationId, io.undertow.server.HttpServerExchange exchange, String resource, String urlPath)
void	destroy()
static void	destroy(String sessionId)
String	getCorrelationId()
Date	getCreateDate()
org.pac4j.core.profile.UserProfile	getCurrentLoggedInUserProfile()
io.undertow.server.HttpServerExchange	getExchange()
ThreadPoolExecutor	getExecutor()
static RuntimePipeline	getPipeline(String id)
String	getSessionID()
Tenant	getTenant()
String	getUser()
boolean	isDestroyed()
boolean	isExchangeInitialized()
static List<RuntimePipeline>	listActivePipelines()
void	logOut()
void	redirectRequest(String path)
void	setCreateDate(Date createDate)
void	setDestroyed(boolean isDestroyed)
void	setUser(String user)
void	writeSnapshot(String resource, String json)

Methods inherited from class java.lang.Object

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

Field Details

payload

public final Map<String,Object> payload

dataPipeLine

public final DataPipeline dataPipeLine

Constructor Details

RuntimePipeline

public RuntimePipeline(Tenant tenant,
 String requestId,
 String correlationId,
 io.undertow.server.HttpServerExchange exchange,
 String resource,
 String urlPath)

Method Details

getExecutor

public ThreadPoolExecutor getExecutor()

isExchangeInitialized

public boolean isExchangeInitialized()

getExchange

public io.undertow.server.HttpServerExchange getExchange()
                                                  throws SnippetException

Throws:

SnippetException

writeSnapshot

public void writeSnapshot(String resource,
 String json)

redirectRequest

public void redirectRequest(String path)
                     throws SnippetException

Throws:

SnippetException

isDestroyed

public boolean isDestroyed()

setDestroyed

public void setDestroyed(boolean isDestroyed)

getSessionID

public String getSessionID()

getCurrentLoggedInUserProfile

public org.pac4j.core.profile.UserProfile getCurrentLoggedInUserProfile()
                                                                 throws SnippetException

Throws:

SnippetException

logOut

public void logOut()
            throws SnippetException

Throws:

SnippetException

create

public static RuntimePipeline create(Tenant tenant,
 String requestId,
 String correlationId,
 io.undertow.server.HttpServerExchange exchange,
 String resource,
 String urlPath)

getPipeline

public static RuntimePipeline getPipeline(String id)

listActivePipelines

public static List<RuntimePipeline> listActivePipelines()

destroy

public void destroy()

destroy

public static void destroy(String sessionId)

getCorrelationId

public String getCorrelationId()

getTenant

public Tenant getTenant()

getCreateDate

public Date getCreateDate()

setCreateDate

public void setCreateDate(Date createDate)

getUser

public String getUser()

setUser

public void setUser(String user)