org.adroitlogic.x.base.connector

Class BiDirectionalEgressConnectorElement<S extends SenderConfig,C extends EgressContext>

java.lang.Object

org.adroitlogic.x.base.processor.AbstractProcessingElement

org.adroitlogic.x.base.connector.EgressConnectorElement<S,C>

org.adroitlogic.x.base.connector.BiDirectionalEgressConnectorElement<S,C>

All Implemented Interfaces:

XEgressConnectorElement<S,C>, Initializable, MetricsReportable, XProcessingElement, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

@MetricsReporter
public abstract class BiDirectionalEgressConnectorElement<S extends SenderConfig,C extends EgressContext>
extends EgressConnectorElement<S,C>

Since:

17.01

Author:

Sajith Dilshan

Field Summary

Fields inherited from class org.adroitlogic.x.base.connector.EgressConnectorElement

logger

Fields inherited from class org.adroitlogic.x.base.processor.AbstractProcessingElement

beanName, context, flowId, project, status

Constructor Summary

Constructors

Constructor and Description
BiDirectionalEgressConnectorElement()

Method Summary

Modifier and Type	Method and Description
long	getEgressTimeout()
XProcessingElement	getResponseProcessor()
protected void	initBiEgressConnector(org.springframework.context.ApplicationContext context)
protected void	initEgressConnector(org.springframework.context.ApplicationContext context)
protected abstract void	prepareResponse(XMessageContext messageContext) This method should be overridden by the Bi-directional egress connectors to perform any preparation tasks on the response message or message context (e.g.: setting a message property/header, setting a context variable) before handing-over the message to the response processor
ExecutionResult	receiveResponse(XMessageContext messageContext)
protected void	setEgressFuture(XMessageContext messageContext, XPlatform platform, XMetricsEngine metricsEngine)
void	setEgressTimeout(long egressTimeout)
void	setResponseProcessor(XProcessingElement responseProcessor)

Methods inherited from class org.adroitlogic.x.base.connector.EgressConnectorElement

getAdditionalProperties, getSenderExchangePattern, getSendingFailedStream, getSendingSuccessStream, getWeight, initElement, newSender, process, sendMessage, setOperation, setWeight

Methods inherited from class org.adroitlogic.x.base.processor.AbstractProcessingElement

destroy, destroyElement, getBeanName, getEntityId, getErrorHandler, getFlowId, getMetricsEngine, getProject, getProjectId, getProjectVersion, getResource, getServerConfig, getStatus, init, processMessage, setBeanName, setErrorHandler, setFlowId, setProject

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.adroitlogic.x.api.connector.XEgressConnectorElement

getEgressContext, getSenderConfig

Methods inherited from interface org.adroitlogic.x.api.processor.XProcessingElement

cast, getBeanName, getFlowId, getProject, getStatus, processMessage, setFlowId, setProject

Methods inherited from interface org.adroitlogic.x.api.dec.Initializable

destroy, init

Methods inherited from interface org.springframework.beans.factory.BeanNameAware

setBeanName

Methods inherited from interface org.adroitlogic.x.api.metrics.MetricsReportable

getEntityId, getFlowId, getMetricsEngine, getProjectId, getProjectVersion

Constructor Detail

BiDirectionalEgressConnectorElement

public BiDirectionalEgressConnectorElement()

Method Detail

initEgressConnector

protected final void initEgressConnector(org.springframework.context.ApplicationContext context)

Overrides:

initEgressConnector in class EgressConnectorElement<S extends SenderConfig,C extends EgressContext>

initBiEgressConnector

protected void initBiEgressConnector(org.springframework.context.ApplicationContext context)

setEgressFuture

protected final void setEgressFuture(XMessageContext messageContext,
                                     XPlatform platform,
                                     XMetricsEngine metricsEngine)

Overrides:

setEgressFuture in class EgressConnectorElement<S extends SenderConfig,C extends EgressContext>

receiveResponse

public final ExecutionResult receiveResponse(XMessageContext messageContext)

Specified by:

receiveResponse in interface XEgressConnectorElement<S extends SenderConfig,C extends EgressContext>

Overrides:

receiveResponse in class EgressConnectorElement<S extends SenderConfig,C extends EgressContext>

prepareResponse

protected abstract void prepareResponse(XMessageContext messageContext)

This method should be overridden by the Bi-directional egress connectors to perform any preparation tasks on the response message or message context (e.g.: setting a message property/header, setting a context variable) before handing-over the message to the response processor

Parameters:

messageContext - XMessageContext object containing the response message

setResponseProcessor

public void setResponseProcessor(XProcessingElement responseProcessor)

getResponseProcessor

public XProcessingElement getResponseProcessor()

getEgressTimeout

public long getEgressTimeout()

setEgressTimeout

public void setEgressTimeout(long egressTimeout)