org.adroitlogic.x.base.connector

Class AbstractBiDirectionalEgressConnectorElement<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.AbstractBiDirectionalEgressConnectorElement<S,C>

All Implemented Interfaces:

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

Direct Known Subclasses:

BiDirectionalAsyncEgressConnectorElement, CallOutEgressConnectorElement

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

The bi-directional egress connector element facilitates out-in MEP where there is a response to the sent out message via the egress connector and that message is to be injected back into the engine for the response flow.

Since:

18.01

Author:

Ruwan Linton

See Also:

BiDirectionalAsyncEgressConnectorElement

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
AbstractBiDirectionalEgressConnectorElement()

Method Summary

Modifier and Type	Method and Description
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)
void	setResponseProcessor(XProcessingElement responseProcessor)

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

continueFlow, getAdditionalProperties, getIntegrationFlow, getOperation, getSender, getSenderExchangePattern, getSendingFailedStream, getSendingSuccessStream, getWeight, initElement, newSender, process, sendMessage, setEgressFuture, setIntegrationFlow, 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

AbstractBiDirectionalEgressConnectorElement

public AbstractBiDirectionalEgressConnectorElement()

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)

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()