org.adroitlogic.x.base.connector

Class BiDirectionalAsyncEgressConnectorElement<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>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BiDirectionalEgressConnectorElement

@MetricsReporter
public abstract class BiDirectionalAsyncEgressConnectorElement<S extends SenderConfig,C extends EgressContext>
extends AbstractBiDirectionalEgressConnectorElement<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
BiDirectionalAsyncEgressConnectorElement()

Method Summary

Modifier and Type	Method and Description
long	getEgressTimeout()
protected void	setEgressFuture(XMessageContext messageContext, XPlatform platform)
void	setEgressTimeout(long egressTimeout)

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

getResponseProcessor, initBiEgressConnector, initEgressConnector, prepareResponse, receiveResponse, setResponseProcessor

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

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

BiDirectionalAsyncEgressConnectorElement

public BiDirectionalAsyncEgressConnectorElement()

Method Detail

setEgressFuture

protected final void setEgressFuture(XMessageContext messageContext,
                                     XPlatform platform)

Overrides:

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

getEgressTimeout

public long getEgressTimeout()

setEgressTimeout

public void setEgressTimeout(long egressTimeout)