Package com.eka.middleware.service

Class DataPipeline

java.lang.Object

com.eka.middleware.service.DataPipeline

public class DataPipeline
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final RuntimePipeline	rp

Constructor Summary

Constructors

Constructor	Description
DataPipeline(RuntimePipeline runtimePipeline, String resource, String urlPath)

Method Summary

Modifier and Type	Method	Description
void	addErrorStack(FlowBasicInfo flowBasicInfo)
void	appLog(String key, String value)
void	appLogMul(String key, String value)
void	appLogProfile(AuthAccount acc)
void	apply(String fqnOfMethod)
void	apply(String fqnOfMethod, javax.json.JsonArray transformers)
void	applyAsync(String fqnOfMethod)
void	applyAsync(String fqnOfMethod, javax.json.JsonArray transformers)
void	applyAsyncQueue(String fqnOfMethod, javax.json.JsonArray transformers, boolean enableResponse)
List<Map<String,Object>>	await(int timeout_MS)
void	clear()
void	clearGlobal()
void	clearServicePayload()
void	clearUserSession()
void	drop(String key)
void	dropGlobal(String key)
String	generateWithUUID(String UUID, int expiresAfterHours, String email, String userId, String name, List<String> groups)
Object	get(String key)
Boolean	getAsBoolean(String pointer)
Byte	getAsByte(String pointer)
Date	getAsDate(String pointer)
Integer	getAsInteger(String pointer)
List	getAsList(String pointer)
Map	getAsMap(String pointer)
Double	getAsNumber(String pointer)
String	getAsString(String pointer)
byte[]	getBody()
InputStream	getBodyAsStream()
String	getCorrelationId()
String	getCurrentResource()
String	getCurrentResourceName()
AuthAccount	getCurrentRuntimeAccount()
String	getCurrentURI()
org.pac4j.core.profile.UserProfile	getCurrentUserProfile()
InputStream	getFile(String paramNameOrFileName)
String	getFileName(InputStream fileStream)
String	getFileName(String paramName)
List<InputStream>	getFiles()
List<Map<String,Object>>	getFuture()
String	getGlobalConfig(String key)
Map<String,Object>	getHeaders()
Integer	getInteger(String key)
Map<String,Object>	getMap()
MultiPart	getMultiPart()
String	getMyConfig(String key)
String	getMyPackageConfig(String key)
String	getMyPackageConfigPath()
Properties	getMyProperties()
Map<String,Object>	getPathParameters()
Map<String,Object>	getQueryParameters()
String	getRemoteIpAddr()
Map<String,Object>	getServicePayload()
String	getSessionId()
int	getStackIndex()
String	getString(String key)
String	getUniqueThreadName()
String	getUrlPath()
Object	getValueByPointer(String pointer)
boolean	isDestroyed()
boolean	isRecordTrace()
void	keyLog(String key, String value)	Deprecated.
List<Map>	listAsyncRunningTasks(String sid)
void	log(String msg)
void	log(String msg, org.apache.logging.log4j.Level level)
void	logDataPipeline()
void	logDataPipeline(org.apache.logging.log4j.Level level)
void	logException(Throwable exception)
void	map(String key, Object value)
void	put(String key, Object value)
void	putAll(Map<String,Object> value)
void	putGlobal(String key, Object value)
void	refresh()
void	restore(String name)
void	save(String name)
void	saveJdbc(DataPipeline dataPipeline, Path path)
void	saveProperties(String path, byte[] data)
void	setBody(byte[] bytes)
void	setBody(File file)
void	setBody(InputStream is, boolean downloadAsStreamFile)
void	setRecordTrace(boolean recordTrace)
void	setResponseStatus(int statusCode)
void	setValueByPointer(String pointer, Object value, String outTypePath)
void	snapAfter(String comment, String guid, Map<String,Object> meta)
void	snapBefore(String comment, String guid)
String	toJson()
String	toXml()
String	toYaml()
void	updateQueuedTaskStatus(String batchId, javax.json.JsonArray transformers, Map<String,Object> asyncOutputDoc, Map<String,Object> metaData)

Methods inherited from class java.lang.Object

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

Field Details

rp

public final RuntimePipeline rp

Constructor Details

DataPipeline

public DataPipeline(RuntimePipeline runtimePipeline,
 String resource,
 String urlPath)

Method Details

addErrorStack

public void addErrorStack(FlowBasicInfo flowBasicInfo)

isDestroyed

public boolean isDestroyed()

get

public Object get(String key)

getString

public String getString(String key)

getInteger

public Integer getInteger(String key)
                   throws SnippetException

Throws:

SnippetException

refresh

public void refresh()

drop

public void drop(String key)

setResponseStatus

public void setResponseStatus(int statusCode)
                       throws SnippetException

Throws:

SnippetException

put

public void put(String key,
 Object value)

map

public void map(String key,
 Object value)

putGlobal

public void putGlobal(String key,
 Object value)

dropGlobal

public void dropGlobal(String key)

clearGlobal

public void clearGlobal()

clearServicePayload

public void clearServicePayload()

getServicePayload

public Map<String,Object> getServicePayload()

putAll

public void putAll(Map<String,Object> value)

getSessionId

public String getSessionId()

getCorrelationId

public String getCorrelationId()

getPathParameters

public Map<String,Object> getPathParameters()

getQueryParameters

public Map<String,Object> getQueryParameters()

getHeaders

public Map<String,Object> getHeaders()

getAsMap

public Map getAsMap(String pointer)

getAsList

public List getAsList(String pointer)

getAsInteger

public Integer getAsInteger(String pointer)

getAsNumber

public Double getAsNumber(String pointer)

getAsByte

public Byte getAsByte(String pointer)

getAsDate

public Date getAsDate(String pointer)

getAsBoolean

public Boolean getAsBoolean(String pointer)

getAsString

public String getAsString(String pointer)

getValueByPointer

public Object getValueByPointer(String pointer)

setValueByPointer

public void setValueByPointer(String pointer,
 Object value,
 String outTypePath)

toJson

public String toJson()

toXml

public String toXml()

getMap

public Map<String,Object> getMap()

toYaml

public String toYaml()

save

public void save(String name)

restore

public void restore(String name)

snapBefore

public void snapBefore(String comment,
 String guid)

snapAfter

public void snapAfter(String comment,
 String guid,
 Map<String,Object> meta)

getBodyAsStream

public InputStream getBodyAsStream()
                            throws SnippetException

Throws:

SnippetException

getFile

public InputStream getFile(String paramNameOrFileName)
                    throws SnippetException

Throws:

SnippetException

getFileName

public String getFileName(String paramName)
                   throws SnippetException

Throws:

SnippetException

getFiles

public List<InputStream> getFiles()
                           throws SnippetException

Throws:

SnippetException

getFileName

public String getFileName(InputStream fileStream)
                   throws SnippetException

Throws:

SnippetException

getBody

public byte[] getBody()
               throws SnippetException

Throws:

SnippetException

setBody

public void setBody(byte[] bytes)
             throws SnippetException

Throws:

SnippetException

setBody

public void setBody(InputStream is,
 boolean downloadAsStreamFile)
             throws SnippetException

Throws:

SnippetException

setBody

public void setBody(File file)
             throws SnippetException

Throws:

SnippetException

getMultiPart

public MultiPart getMultiPart()
                       throws SnippetException

Throws:

SnippetException

getUniqueThreadName

public String getUniqueThreadName()

getCurrentResource

public String getCurrentResource()

getCurrentResourceName

public String getCurrentResourceName()

clear

public void clear()

apply

public void apply(String fqnOfMethod)
           throws SnippetException

Throws:

SnippetException

apply

public void apply(String fqnOfMethod,
 javax.json.JsonArray transformers)
           throws SnippetException

Throws:

SnippetException

getFuture

public List<Map<String,Object>> getFuture()

updateQueuedTaskStatus

public void updateQueuedTaskStatus(String batchId,
 javax.json.JsonArray transformers,
 Map<String,Object> asyncOutputDoc,
 Map<String,Object> metaData)

await

public List<Map<String,Object>> await(int timeout_MS)
                               throws SnippetException

Throws:

SnippetException

applyAsync

public void applyAsync(String fqnOfMethod,
 javax.json.JsonArray transformers)
                throws SnippetException

Throws:

SnippetException

applyAsyncQueue

public void applyAsyncQueue(String fqnOfMethod,
 javax.json.JsonArray transformers,
 boolean enableResponse)
                     throws SnippetException

Throws:

SnippetException

listAsyncRunningTasks

public List<Map> listAsyncRunningTasks(String sid)

applyAsync

public void applyAsync(String fqnOfMethod)
                throws SnippetException

Throws:

SnippetException

getMyConfig

public String getMyConfig(String key)
                   throws SnippetException

Throws:

SnippetException

getMyPackageConfig

public String getMyPackageConfig(String key)
                          throws SnippetException

Throws:

SnippetException

saveJdbc

public void saveJdbc(DataPipeline dataPipeline,
 Path path)
              throws SnippetException,
IOException

Throws:

SnippetException

IOException

saveProperties

public void saveProperties(String path,
 byte[] data)

getMyPackageConfigPath

public String getMyPackageConfigPath()

getMyProperties

public Properties getMyProperties()
                           throws SnippetException

Throws:

SnippetException

logDataPipeline

public void logDataPipeline(org.apache.logging.log4j.Level level)

logException

public void logException(Throwable exception)

logDataPipeline

public void logDataPipeline()

log

public void log(String msg)

keyLog

@Deprecated
public void keyLog(String key,
 String value)

Deprecated.

appLog

public void appLog(String key,
 String value)

appLogMul

public void appLogMul(String key,
 String value)

appLogProfile

public void appLogProfile(AuthAccount acc)

log

public void log(String msg,
 org.apache.logging.log4j.Level level)

getGlobalConfig

public String getGlobalConfig(String key)
                       throws SnippetException

Throws:

SnippetException

getStackIndex

public int getStackIndex()

getUrlPath

public String getUrlPath()

getCurrentRuntimeAccount

public AuthAccount getCurrentRuntimeAccount()
                                     throws SnippetException

Throws:

SnippetException

getCurrentUserProfile

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

Throws:

SnippetException

clearUserSession

public void clearUserSession()
                      throws SnippetException

Throws:

SnippetException

getRemoteIpAddr

public String getRemoteIpAddr()

getCurrentURI

public String getCurrentURI()

generateWithUUID

public String generateWithUUID(String UUID,
 int expiresAfterHours,
 String email,
 String userId,
 String name,
 List<String> groups)
                        throws Exception

Throws:

Exception

isRecordTrace

public boolean isRecordTrace()

setRecordTrace

public void setRecordTrace(boolean recordTrace)