org.adroitlogic.x.base.connector.call

Class OneWayEgressConnectorElement

java.lang.Object

org.adroitlogic.x.base.processor.AbstractProcessingElement

org.adroitlogic.x.base.connector.EgressConnectorElement<SelfSenderConfig,BareEgressContext>

org.adroitlogic.x.base.connector.call.OneWayEgressConnectorElement

All Implemented Interfaces:

XEgressConnectorElement<SelfSenderConfig,BareEgressContext>, Initializable, MetricsReportable, XProcessingElement, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public abstract class OneWayEgressConnectorElement
extends EgressConnectorElement<SelfSenderConfig,BareEgressContext>

A one-way egress connector element that can be used as the base class for a send out using a Java client library such as Kafka or Amazon SQS to call out

Since:

17.07.1

Author:

Ruwan Linton

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

Method Summary

Modifier and Type	Method and Description
BareEgressContext	getEgressContext(XMessageContext messageContext) Gives the bare egress context without any information on the connector context as the connector is supposed to be keeping all its context information
SelfSenderConfig	getSenderConfig() Gives the sender configuration without any connector or transport specific information, as the one-way egress connectors are supposed to be using the configuration within the connector without passing anything to the transport layer
protected TransportSender<SelfSenderConfig,BareEgressContext>	newSender(org.springframework.context.ApplicationContext context) Gives the wrapped transport sender for the one-way send out operation
protected abstract void	sendOut(XMessageContext messageContext) Uses the message context passed into this method to invoke the client library call of the SDK for the invocation.

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

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

OneWayEgressConnectorElement

public OneWayEgressConnectorElement()

Method Detail

sendOut

protected abstract void sendOut(XMessageContext messageContext)

Uses the message context passed into this method to invoke the client library call of the SDK for the invocation. This method has to be implemented by any egress connector that emulates an existing client library

Parameters:

messageContext - the message context to be used for the invocation

getSenderConfig

public SelfSenderConfig getSenderConfig()

Gives the sender configuration without any connector or transport specific information, as the one-way egress connectors are supposed to be using the configuration within the connector without passing anything to the transport layer

Returns:

a self sender configuration without connector nor transport specific information

getEgressContext

public BareEgressContext getEgressContext(XMessageContext messageContext)

Gives the bare egress context without any information on the connector context as the connector is supposed to be keeping all its context information

Parameters:

messageContext - message context to create the bare egress context

Returns:

the bare egress context singleton instance

newSender

protected TransportSender<SelfSenderConfig,BareEgressContext> newSender(org.springframework.context.ApplicationContext context)

Gives the wrapped transport sender for the one-way send out operation

Specified by:

newSender in class EgressConnectorElement<SelfSenderConfig,BareEgressContext>

Parameters:

context - the application context used for the sender creation

Returns:

the one-way transport sender that calls back to the connector for the send out operation