public class CallMediator extends AbstractMediator implements ManagedLifecycle
ContinuationState
which are stored in the ContinuationStateStack
which resides in the MessageContext.
These ContinuationStates are used to mediate the response message and continue the message flow.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_AXIS2_XML |
static java.lang.String |
DEFAULT_CLIENT_REPO |
static java.lang.String |
INTERMEDIATE_ORIGINAL_BODY |
static java.lang.String |
IS_SOURCE_AVAILABLE |
static java.lang.String |
IS_TARGET_AVAILABLE |
static java.lang.String |
JSON_TYPE |
static java.lang.String |
ORIGINAL_CONTENT_TYPE |
static java.lang.String |
ORIGINAL_MESSAGE_TYPE |
static java.lang.String |
ORIGINAL_TRANSPORT_HEADERS |
static java.lang.String |
SOURCE_MESSAGE_TYPE |
static java.lang.String |
TARGET_FOR_INBOUND_PAYLOAD |
log, trace, traceState
Constructor and Description |
---|
CallMediator() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
This method should implement the destroying of the
implemented parts of the configuration.
|
java.lang.String |
getAxis2xml() |
java.lang.String |
getClientRepository() |
Endpoint |
getEndpoint() |
boolean |
getInitClientOptions() |
Source |
getSourceForOutboundPayload() |
java.lang.String |
getSourceMessageType() |
Target |
getTargetForInboundPayload() |
void |
init(SynapseEnvironment synapseEnvironment)
This method should implement the initialization of the
implemented parts of the configuration.
|
boolean |
isBlocking() |
boolean |
isContentAware()
Setting return blocking makes CallMediator access the message’s content in blocking mode when mediating messages
Fixes product-ei #1805, #3015
|
boolean |
isSourceAvailable() |
boolean |
isTargetAvailable() |
boolean |
mediate(MessageContext synInCtx)
This will call the send method on the messages with implicit message parameters
or else if there is an endpoint, with that endpoint parameters
|
void |
postMediate(MessageContext response,
java.lang.String originalMessageType,
java.lang.String originalContentType,
java.util.Map originalTransportHeaders) |
void |
setAxis2xml(java.lang.String axis2xml) |
void |
setBlocking(boolean blocking) |
void |
setClientRepository(java.lang.String clientRepository) |
void |
setComponentStatisticsId(ArtifactHolder holder) |
void |
setEndpoint(Endpoint endpoint) |
void |
setInitClientOptions(boolean initClientOptions) |
void |
setSourceAvailable(boolean sourceAvailable) |
void |
setSourceForOutboundPayload(Source sourceForOutboundPayload) |
void |
setSourceMessageType(java.lang.String sourceMessageType) |
void |
setTargetAvailable(boolean targetAvailable) |
void |
setTargetForInboundPayload(Target targetForInboundPayload) |
auditLog, auditWarn, configure, disableStatistics, disableTracing, divertMediationRoute, enableStatistics, enableTracing, getAspectConfiguration, getCommentsList, getDescription, getInputType, getLastSequenceFaultHandler, getLog, getMediatorName, getMediatorPosition, getOutputType, getRegisteredMediationFlowPoint, getShortDescription, getTraceState, getType, handleException, handleException, isBreakPoint, isContentAltering, isSkipEnabled, isStatisticsEnable, isTraceOn, isTraceOrDebugOn, isTracingEnabled, registerMediationFlowPoint, reportCloseStatistics, reportOpenStatistics, setBreakPoint, setCommentsList, setDescription, setEffectiveTraceState, setMediatorPosition, setShortDescription, setSkipEnabled, setTraceState, shouldCaptureTracing, shouldTrace, shouldTrace, traceOrDebug, traceOrDebugWarn, unregisterMediationFlowPoint
public static final java.lang.String DEFAULT_CLIENT_REPO
public static final java.lang.String DEFAULT_AXIS2_XML
public static final java.lang.String INTERMEDIATE_ORIGINAL_BODY
public static final java.lang.String TARGET_FOR_INBOUND_PAYLOAD
public static final java.lang.String ORIGINAL_MESSAGE_TYPE
public static final java.lang.String SOURCE_MESSAGE_TYPE
public static final java.lang.String IS_SOURCE_AVAILABLE
public static final java.lang.String IS_TARGET_AVAILABLE
public static final java.lang.String ORIGINAL_TRANSPORT_HEADERS
public static final java.lang.String ORIGINAL_CONTENT_TYPE
public static final java.lang.String JSON_TYPE
public boolean mediate(MessageContext synInCtx)
public void postMediate(MessageContext response, java.lang.String originalMessageType, java.lang.String originalContentType, java.util.Map originalTransportHeaders)
public Endpoint getEndpoint()
public void setEndpoint(Endpoint endpoint)
public void init(SynapseEnvironment synapseEnvironment)
ManagedLifecycle
init
in interface ManagedLifecycle
synapseEnvironment
- SynapseEnvironment to be used for initializationpublic void destroy()
ManagedLifecycle
destroy
in interface ManagedLifecycle
public boolean isContentAware()
isContentAware
in interface Mediator
isContentAware
in class AbstractMediator
public boolean isBlocking()
public void setBlocking(boolean blocking)
public boolean getInitClientOptions()
public void setInitClientOptions(boolean initClientOptions)
public java.lang.String getClientRepository()
public void setClientRepository(java.lang.String clientRepository)
public java.lang.String getAxis2xml()
public void setAxis2xml(java.lang.String axis2xml)
public void setComponentStatisticsId(ArtifactHolder holder)
setComponentStatisticsId
in interface Mediator
setComponentStatisticsId
in class AbstractMediator
public boolean isSourceAvailable()
public void setSourceAvailable(boolean sourceAvailable)
public boolean isTargetAvailable()
public void setTargetAvailable(boolean targetAvailable)
public Source getSourceForOutboundPayload()
public void setSourceForOutboundPayload(Source sourceForOutboundPayload)
public Target getTargetForInboundPayload()
public void setTargetForInboundPayload(Target targetForInboundPayload)
public java.lang.String getSourceMessageType()
public void setSourceMessageType(java.lang.String sourceMessageType)
Copyright © 2005-2021 Apache Software Foundation. All Rights Reserved.