org.adroitlogic.x.base.processor

Class TraceableProcessingElement

java.lang.Object

org.adroitlogic.x.base.processor.TraceableProcessingElement

All Implemented Interfaces:

Initializable, XProcessingElement, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public final class TraceableProcessingElement
extends Object
implements XProcessingElement

Internal wrapper element used in development and test environments to provide a wrapper that helps trace the messages flow though the processing elements. This wrapping is automatic and is transparent from the users in general

Since:

17.01

Author:

Ruwan Linton

Constructor Summary

Constructors

Constructor and Description
TraceableProcessingElement(XProcessingElement processingElement, String callerBeanName, String outPortDisplayName)

Method Summary

Modifier and Type	Method and Description
<T extends XProcessingElement> T	cast(Class<T> clazz)
void	destroy()
String	getBeanName()
String	getFlowId()
XProcessingElement	getProcessingElement()
XProject	getProject()
Status	getStatus()
void	init(org.springframework.context.ApplicationContext context)
ExecutionResult	processMessage(XMessageContext messageContext) Executes the processing element specific processing of the message
void	setBeanName(String s)
void	setFlowId(String flowID)
void	setProject(XProject project)

Methods inherited from class java.lang.Object

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

Constructor Detail

TraceableProcessingElement

public TraceableProcessingElement(XProcessingElement processingElement,
                                  String callerBeanName,
                                  String outPortDisplayName)

Method Detail

getBeanName

public String getBeanName()

Specified by:

getBeanName in interface XProcessingElement

processMessage

public ExecutionResult processMessage(XMessageContext messageContext)

Description copied from interface: XProcessingElement

Executes the processing element specific processing of the message

Specified by:

processMessage in interface XProcessingElement

Parameters:

messageContext - XMessageContext with the message to be processed

Returns:

the execution result of the processing of the message

init

public void init(org.springframework.context.ApplicationContext context)

Specified by:

init in interface Initializable

destroy

public void destroy()

Specified by:

destroy in interface Initializable

cast

public <T extends XProcessingElement> T cast(Class<T> clazz)

Specified by:

cast in interface XProcessingElement

getFlowId

public String getFlowId()

Specified by:

getFlowId in interface XProcessingElement

setFlowId

public void setFlowId(String flowID)

Specified by:

setFlowId in interface XProcessingElement

getProject

public XProject getProject()

Specified by:

getProject in interface XProcessingElement

setProject

public void setProject(XProject project)

Specified by:

setProject in interface XProcessingElement

setBeanName

public void setBeanName(String s)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

getStatus

public final Status getStatus()

Specified by:

getStatus in interface XProcessingElement

getProcessingElement

public XProcessingElement getProcessingElement()