public abstract class CallOutEgressConnectorElement extends AbstractBiDirectionalEgressConnectorElement<SelfSenderConfig,BareEgressContext>
logger
Constructor and Description |
---|
CallOutEgressConnectorElement() |
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 call-out and 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 call-out operation
|
protected void |
prepareResponse(XMessageContext messageContext)
A blank method implementation for the prepare response as the response is anyway been provided by the
sendReceiveMessage(XMessageContext) method of this same class |
(package private) ExecutionResult |
sendReceive(XMessageContext messageContext)
CallOut transport sender uses this method to invoke the actual send receive operation and injects the response
back to the caller
|
protected abstract XMessage |
sendReceiveMessage(XMessageContext messageContext)
Uses the message context passed into this method to invoke the client library call of the SDK and returns the
composed response message to be injected back into the engine as the resulting response of the invocation.
|
getResponseProcessor, initBiEgressConnector, initEgressConnector, receiveResponse, setResponseProcessor
continueFlow, getAdditionalProperties, getIntegrationFlow, getOperation, getSender, getSenderExchangePattern, getSendingFailedStream, getSendingSuccessStream, getWeight, initElement, process, sendMessage, setEgressFuture, setIntegrationFlow, setOperation, setWeight
destroy, destroyElement, getBeanName, getEntityId, getErrorHandler, getFlowId, getMetricsEngine, getProject, getProjectId, getProjectVersion, getResource, getServerConfig, getStatus, init, processMessage, setBeanName, setErrorHandler, setFlowId, setProject
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
cast, getBeanName, getFlowId, getProject, getStatus, processMessage, setFlowId, setProject
destroy, init
getEntityId, getFlowId, getMetricsEngine, getProjectId, getProjectVersion
protected abstract XMessage sendReceiveMessage(XMessageContext messageContext)
messageContext
- the message context to be used for the invocationExecutionResult sendReceive(XMessageContext messageContext)
messageContext
- the message to be sentpublic SelfSenderConfig getSenderConfig()
public BareEgressContext getEgressContext(XMessageContext messageContext)
messageContext
- message context to create the bare egress contextprotected TransportSender<SelfSenderConfig,BareEgressContext> newSender(org.springframework.context.ApplicationContext context)
newSender
in class EgressConnectorElement<SelfSenderConfig,BareEgressContext>
context
- the application context used for the sender creationprotected final void prepareResponse(XMessageContext messageContext)
sendReceiveMessage(XMessageContext)
method of this same classprepareResponse
in class AbstractBiDirectionalEgressConnectorElement<SelfSenderConfig,BareEgressContext>
messageContext
- XMessageContext
object containing the response messageCopyright © 2016–2019 AdroitLogic. All rights reserved.