Modifier and Type | Method and Description |
---|---|
void |
FaultHandler.handleFault(MessageContext synCtx) |
void |
FaultHandler.handleFault(MessageContext synCtx,
Exception e)
Extract and set ERROR_MESSAGE and ERROR_DETAIL to the message context from the Exception
|
boolean |
SynapseHandler.handleRequestInFlow(MessageContext synCtx)
Handle request message coming into the engine
|
boolean |
SynapseHandler.handleRequestOutFlow(MessageContext synCtx)
Handle request message going out from the engine
|
boolean |
SynapseHandler.handleResponseInFlow(MessageContext synCtx)
Handle response message coming into the engine
|
boolean |
SynapseHandler.handleResponseOutFlow(MessageContext synCtx)
Handle response message going out from the engine
|
boolean |
Mediator.mediate(MessageContext synCtx)
Invokes the mediator passing the current message for mediation.
|
abstract void |
FaultHandler.onFault(MessageContext synCtx)
This will be executed to handle any Exceptions occurred within the Synapse environment.
|
void |
Mediator.reportCloseStatistics(MessageContext synCtx,
Integer currentIndex)
Report Close Statistic Event for the Mediator
|
Integer |
Mediator.reportOpenStatistics(MessageContext synCtx,
boolean isContentAltering)
Report Open Statistic Event for the Mediator
|
Modifier and Type | Method and Description |
---|---|
static AspectConfiguration |
AspectConfigurationDetectionStrategy.getAspectConfiguration(MessageContext synCtx)
Factory method to create the AspectConfiguration when there is no a defined main sequence and
only there is a set of mediators.
|
Modifier and Type | Method and Description |
---|---|
static void |
CallbackStatisticCollector.addCallback(MessageContext messageContext,
String callbackId)
Enqueue CallbackSentEvent event to the event queue.
|
protected static void |
RuntimeStatisticCollector.addEvent(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to just add event without changing counts.
|
protected static void |
RuntimeStatisticCollector.addEventAndCloseFlow(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to add event and close the message flow static collection.
|
protected static void |
RuntimeStatisticCollector.addEventAndDecrementCallbackCount(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to add event and decrement call back count, which denotes, call back has been received.
|
protected static void |
RuntimeStatisticCollector.addEventAndDecrementCount(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to add event and decrement stat count, which denotes, closing event happened.
|
protected static void |
RuntimeStatisticCollector.addEventAndIncrementCallbackCount(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to add event and increment call back count, which notifies that a callback has been registered
|
protected static void |
RuntimeStatisticCollector.addEventAndIncrementCount(MessageContext messageContext,
StatisticsReportingEvent event)
Helper method to add event and increment stat count so that it denotes, open event is added.
|
static void |
CallbackStatisticCollector.callbackCompletionEvent(MessageContext oldMessageContext,
String callbackId)
Enqueue CallbackCompletionEvent event to the event queue.
|
static void |
CloseEventCollector.closeEntryEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
Integer currentIndex,
boolean isContentAltering)
Enqueue statistics event to the event queue.
|
static void |
CloseEventCollector.closeFlowForcefully(MessageContext messageContext,
boolean error)
Enqueue statistics event to the event queue.
|
static void |
OpenEventCollector.openContinuationEvents(MessageContext synCtx)
Add event in to the event queue.
|
static void |
CallbackStatisticCollector.reportCallbackHandlingCompletion(MessageContext synapseOutMsgCtx,
String callbackId)
Enqueue CallbackHandledEvent event to the event queue.
|
static Integer |
OpenEventCollector.reportChildEntryEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
AspectConfiguration aspectConfiguration,
boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.
|
static Integer |
OpenEventCollector.reportEntryEvent(MessageContext messageContext,
String componentName,
AspectConfiguration aspectConfiguration,
ComponentType componentType)
Enqueue StatisticOpenEvent to the event Queue.
|
static void |
FaultStatisticCollector.reportFault(MessageContext messageContext)
Enqueue Fault Event to the event queue indicating that fault has occurred in the message flow.
|
static Integer |
OpenEventCollector.reportFlowAggregateEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
AspectConfiguration aspectConfiguration,
boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.
|
static void |
OpenEventCollector.reportFlowAsynchronousEvent(MessageContext messageContext)
Enqueue StatisticOpenEvent for asynchronous invocation.
|
static Integer |
OpenEventCollector.reportFlowContinuableEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
AspectConfiguration aspectConfiguration,
boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.
|
static Integer |
OpenEventCollector.reportFlowSplittingEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
AspectConfiguration aspectConfiguration,
boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.
|
protected static void |
RuntimeStatisticCollector.setStatisticsTraceId(MessageContext msgCtx)
Set message Id of the message context as statistic trace Id at the beginning of the statistic flow.
|
static boolean |
RuntimeStatisticCollector.shouldReportStatistic(MessageContext messageContext)
Returns true if statistics is collected in this message flow path.
|
static void |
CloseEventCollector.tryEndFlow(MessageContext messageContext,
String componentName,
ComponentType componentType,
Integer currentIndex,
boolean isContentAltering)
Enqueue statistics events to the event queue to close and try to finish the flow.
|
static void |
CallbackStatisticCollector.updateParentsForCallback(MessageContext oldMessageContext,
String callbackId)
Enqueue CallbackReceivedEvent event to the event queue.
|
Modifier and Type | Method and Description |
---|---|
static void |
StatisticDataCollectionHelper.collectAggregatedParents(List<MessageContext> messages,
MessageContext newCtx)
This method is used to collect all the parent indexes from message contexts which contributes to aggregate
message at the end of the aggregation.
|
static void |
StatisticDataCollectionHelper.collectData(MessageContext messageContext,
boolean isContentAltering,
Boolean isCollectingTracing,
StatisticDataUnit statisticDataUnit)
Collect necessary statistics data from the message context.
|
static String |
TracingDataCollectionHelper.collectPayload(MessageContext messageContext)
Extract payload from the synapse message context.
|
static Map<String,Object> |
TracingDataCollectionHelper.extractContextProperties(MessageContext synCtx)
Extract properties from the synapse message context.
|
static Map<String,Object> |
TracingDataCollectionHelper.extractTransportProperties(MessageContext synCtx)
Extract transport headers from the synapse message context.
|
static int |
StatisticDataCollectionHelper.getFlowPosition(MessageContext messageContext)
Get message flow position for the current component.
|
static int |
StatisticDataCollectionHelper.getParentFlowPosition(MessageContext messageContext,
Integer newParentIndex)
Get parent of this statistic component and sets current message flow position as next components parent.
|
static List<Integer> |
StatisticDataCollectionHelper.getParentList(MessageContext messageContext)
Get Parent list for this component.
|
static String |
StatisticDataCollectionHelper.getStatisticTraceId(MessageContext messageContext)
Get statistic trace id for this message flow.
|
static boolean |
StatisticDataCollectionHelper.isOutOnlyFlow(MessageContext messageContext)
Checks is this is a Out_Only message flow.
|
Modifier and Type | Method and Description |
---|---|
static void |
StatisticDataCollectionHelper.collectAggregatedParents(List<MessageContext> messages,
MessageContext newCtx)
This method is used to collect all the parent indexes from message contexts which contributes to aggregate
message at the end of the aggregation.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TenantInfoConfigurator.applyTenantInfo(MessageContext out) |
boolean |
TenantInfoConfigurator.extractTenantInfo(MessageContext in) |
Modifier and Type | Method and Description |
---|---|
boolean |
AnonymousListMediator.mediate(MessageContext synCtx) |
boolean |
SwitchCase.mediate(MessageContext synCtx)
To delegate message mediation to list mediator
|
abstract String |
SynapsePath.stringValueOf(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
static void |
ContinuationStackManager.addReliantContinuationState(MessageContext synCtx,
int subBranch,
int position)
Add a ReliantContinuationState to the top SeqContinuationState in the stack.
|
static void |
ContinuationStackManager.addSeqContinuationState(MessageContext synCtx,
String seqName,
SequenceType seqType)
Add new SeqContinuationState to the stack.
|
static void |
ContinuationStackManager.clearStack(MessageContext synCtx)
Remove all ContinuationStates from ContinuationState Stack
|
static boolean |
ContinuationStackManager.isSkipSeqContinuationStateAddition(MessageContext synCtx)
Check whether sequence continuation state addition need to be skipped
|
static ContinuationState |
ContinuationStackManager.peakContinuationStateStack(MessageContext synCtx)
Peek from Continuation Stack
|
static void |
ContinuationStackManager.popContinuationStateStack(MessageContext synCtx)
Pop from Continuation Stack
|
static void |
ContinuationStackManager.pushFaultHandler(MessageContext synCtx,
SeqContinuationState seqContState)
Push fault handler for the received continuation call response.
|
static void |
ContinuationStackManager.removeReliantContinuationState(MessageContext synCtx)
Remove a ReliantContinuationState from the top SeqContinuationState in the stack.
|
static void |
ContinuationStackManager.removeSeqContinuationState(MessageContext synCtx,
SequenceType seqType)
Remove top SeqContinuationState from the stack.
|
static SequenceMediator |
ContinuationStackManager.retrieveSequence(MessageContext synCtx,
SeqContinuationState seqContState)
Retrieve the sequence from Continuation state which message should be injected to.
|
static void |
ContinuationStackManager.updateSeqContinuationState(MessageContext synCtx,
int position)
Update SeqContinuationState with the current mediator position in the sequence.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
SynapseEnvironment.createMessageContext()
Creates a new Synapse
MessageContext instance. |
Modifier and Type | Method and Description |
---|---|
void |
SynapseEnvironment.injectAsync(MessageContext smc,
SequenceMediator seq)
This method injects a new message into the Synapse engine for the mediation
by the specified sequence.
|
boolean |
SynapseEnvironment.injectInbound(MessageContext smc,
SequenceMediator seq,
boolean sequential)
This method injects a new message into the Synapse engine for the mediation
by the specified sequence.
|
boolean |
SynapseEnvironment.injectMessage(MessageContext smc)
This method injects a new message into the Synapse engine.
|
boolean |
SynapseEnvironment.injectMessage(MessageContext smc,
SequenceMediator seq)
Inject message to the sequence in synchronous manner
|
void |
SynapseEnvironment.send(EndpointDefinition endpoint,
MessageContext smc)
This method allows a message to be sent through the underlying SOAP engine.
|
Modifier and Type | Class and Description |
---|---|
class |
Axis2MessageContext
This is the MessageContext implementation that synapse uses almost all the time because Synapse
is implemented on top of the Axis2
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
Axis2SynapseEnvironment.createMessageContext()
This method will be used to create a new MessageContext in the Axis2 environment for
Synapse.
|
static MessageContext |
MessageContextCreatorForAxis2.getSynapseMessageContext(org.apache.axis2.context.MessageContext axisMsgCtx) |
MessageContext |
AsyncCallback.getSynapseOutMsgCtx() |
Modifier and Type | Method and Description |
---|---|
void |
Axis2SynapseEnvironment.injectAsync(MessageContext synCtx,
SequenceMediator seq) |
boolean |
Axis2SynapseEnvironment.injectInbound(MessageContext synCtx,
SequenceMediator seq,
boolean sequential)
Used by inbound polling endpoints to inject the message to synapse engine
|
boolean |
Axis2SynapseEnvironment.injectMessage(MessageContext synCtx) |
boolean |
Axis2SynapseEnvironment.injectMessage(MessageContext smc,
SequenceMediator seq) |
void |
ProxyService.registerFaultHandler(MessageContext synCtx)
Register the fault handler for the message context
|
static void |
Axis2FlexibleMEPClient.send(EndpointDefinition endpoint,
MessageContext synapseOutMessageContext)
Based on the Axis2 client code.
|
void |
Axis2SynapseEnvironment.send(EndpointDefinition endpoint,
MessageContext synCtx)
This will be used for sending the message provided, to the endpoint specified by the
EndpointDefinition using the axis2 environment.
|
static void |
Axis2Sender.sendBack(MessageContext smc)
Send a response back to a client of Synapse
|
static void |
Axis2Sender.sendOn(EndpointDefinition endpoint,
MessageContext synapseInMessageContext)
Send a message out from the Synapse engine to an external service
|
Constructor and Description |
---|
AsyncCallback(org.apache.axis2.context.MessageContext messageContext,
MessageContext synapseOutMsgCtx) |
Modifier and Type | Method and Description |
---|---|
void |
SynapseDebugManager.advertiseMediationFlowBreakPoint(MessageContext synCtx,
SynapseMediationFlowPoint breakPoint)
advertise a mediation breakpoint to the communication channel
|
void |
SynapseDebugManager.advertiseMediationFlowSkip(MessageContext synCtx,
SynapseMediationFlowPoint skipPoint)
advertise a mediation skip to the communication channel
|
void |
SynapseDebugManager.advertiseMediationFlowStartPoint(MessageContext synCtx)
Related to advertising the point where mediation flow starts.
|
void |
SynapseDebugManager.advertiseMediationFlowTerminatePoint(MessageContext synCtx)
related to advertising mediation flow terminating point to the communication channel
|
void |
SynapseDebugManager.setMessageContext(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
String |
EndpointDefinition.evaluateDynamicEndpointSecurityPolicy(MessageContext synCtx)
Evaluates the ws security policy path dynamically
|
long |
EndpointDefinition.evaluateDynamicEndpointTimeout(MessageContext synCtx) |
protected void |
AbstractEndpoint.evaluateProperties(MessageContext synCtx)
Evaluates the endpoint properties based on the current message context and set
the properties to the message context appropriately
|
void |
HTTPEndpoint.executeEpTypeSpecificFunctions(MessageContext synCtx) |
void |
AbstractEndpoint.executeEpTypeSpecificFunctions(MessageContext synCtx) |
protected String |
DynamicLoadbalanceEndpoint.extractSessionID(MessageContext synCtx,
String key) |
String |
EndpointDefinition.getAddress(MessageContext messageContext)
This should return the absolute EPR address referenced by the named endpoint.
|
protected Endpoint |
LoadbalanceEndpoint.getNextChild(MessageContext synCtx) |
Endpoint |
IndirectEndpoint.getRealEndpoint(MessageContext synCtx)
Get the real endpoint
|
protected void |
AbstractEndpoint.informFailure(MessageContext synCtx,
int errorCode,
String errorMsg) |
protected boolean |
AbstractEndpoint.isRetry(MessageContext synCtx) |
protected boolean |
AbstractEndpoint.isSuspendFault(MessageContext synCtx)
Is this a fault that should put the endpoint on SUSPEND? or is this a fault to ignore?
|
protected boolean |
AbstractEndpoint.isTimeout(MessageContext synCtx)
Is this [fault] message a timeout?
|
protected boolean |
AbstractEndpoint.isTraceOn(MessageContext msgCtx)
Should this mediator perform tracing? True if its explicitly asked to
trace, or its parent has been asked to trace and it does not reject it
|
protected void |
AbstractEndpoint.logOnChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
RecipientListEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
FailoverEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
SALoadbalanceEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synCtx)
It is logically incorrect to failover a session affinity endpoint after the session has started.
|
void |
AbstractEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
LoadbalanceEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
Endpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext)
Endpoints that contain other endpoints should implement this method.
|
void |
HTTPEndpoint.onFault(MessageContext synCtx) |
void |
AbstractEndpoint.onFault(MessageContext synCtx)
On a fault, propagate to parent if any, or call into the fault handler
|
void |
WSDLEndpoint.onFault(MessageContext synCtx) |
void |
DefaultEndpoint.onFault(MessageContext synCtx) |
void |
AddressEndpoint.onFault(MessageContext synCtx) |
protected void |
AbstractEndpoint.prepareForEndpointStatistics(MessageContext synCtx)
Process statistics for this message
|
void |
RecipientListEndpoint.send(MessageContext synCtx) |
void |
IndirectEndpoint.send(MessageContext synCtx)
Send by calling to the real endpoint
|
void |
FailoverEndpoint.send(MessageContext synCtx) |
void |
HTTPEndpoint.send(MessageContext synCtx) |
void |
TemplateEndpoint.send(MessageContext synCtx) |
void |
SALoadbalanceEndpoint.send(MessageContext synCtx) |
void |
AbstractEndpoint.send(MessageContext synCtx) |
void |
WSDLEndpoint.send(MessageContext synCtx) |
void |
ResolvingEndpoint.send(MessageContext synCtx) |
void |
DefaultEndpoint.send(MessageContext synCtx) |
void |
ClassEndpoint.send(MessageContext synCtx) |
void |
ServiceDynamicLoadbalanceEndpoint.send(MessageContext synCtx) |
void |
LoadbalanceEndpoint.send(MessageContext synCtx) |
void |
AddressEndpoint.send(MessageContext synCtx) |
void |
DynamicLoadbalanceEndpoint.send(MessageContext synCtx) |
void |
Endpoint.send(MessageContext synMessageContext)
Sends the message context according to an endpoint specific behavior.
|
void |
RecipientListEndpoint.sendMessage(MessageContext synCtx) |
void |
TemplateEndpoint.sendMessage(MessageContext synCtx) |
void |
SALoadbalanceEndpoint.sendMessage(MessageContext synCtx) |
void |
ResolvingEndpoint.sendMessage(MessageContext synCtx)
Send by calling to the real endpoint
|
void |
ClassEndpoint.sendMessage(MessageContext synMessageContext)
Override the
AbstractEndpoint.send() to have a custom
message send out logic. |
protected void |
DynamicLoadbalanceEndpoint.sendToApplicationMember(MessageContext synCtx,
org.apache.axis2.clustering.Member currentMember,
DynamicLoadbalanceFaultHandler faultHandler,
boolean newSession) |
protected void |
DynamicLoadbalanceEndpoint.setCookieHeader(MessageContext synCtx) |
protected void |
AbstractEndpoint.setErrorOnMessage(MessageContext synCtx,
Integer errorCode,
String errorMsg) |
protected void |
DynamicLoadbalanceEndpoint.setupTransportHeaders(MessageContext synCtx)
Adding the X-Forwarded-For/X-Originating-IP headers to the outgoing message.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
WeightedRoundRobin.getNextEndpoint(MessageContext synapseMessageContext,
AlgorithmContext algorithmContext) |
Endpoint |
WeightedRRLCAlgorithm.getNextEndpoint(MessageContext messageContext,
AlgorithmContext algorithmContext) |
Endpoint |
LoadbalanceAlgorithm.getNextEndpoint(MessageContext synapseMessageContext,
AlgorithmContext algorithmContext)
This method returns the next node according to the algorithm implementation.
|
Endpoint |
RoundRobin.getNextEndpoint(MessageContext synCtx,
AlgorithmContext algorithmContext)
Choose an active endpoint using the round robin algorithm.
|
Modifier and Type | Method and Description |
---|---|
protected SessionCookie |
AbstractDispatcher.extractSessionCookie(MessageContext synCtx,
String key) |
protected String |
AbstractDispatcher.extractSessionID(MessageContext synCtx,
String key) |
protected List<String> |
HttpSessionDispatcher.extractSessionIDs(MessageContext synCtx,
String key) |
SessionInformation |
SimpleClientSessionDispatcher.getSession(MessageContext synCtx) |
SessionInformation |
SoapSessionDispatcher.getSession(MessageContext synCtx)
Gives the endpoint based on the service group context ID of the request message.
|
SessionInformation |
Dispatcher.getSession(MessageContext synCtx)
Dispatcher should check the session id pattern in the synapseMessageContext and return the
matching endpoint for that session id, if available.
|
SessionInformation |
HttpSessionDispatcher.getSession(MessageContext synCtx)
Check if "Cookie" HTTP header is available.
|
void |
SimpleClientSessionDispatcher.removeSessionID(MessageContext syCtx) |
void |
SoapSessionDispatcher.removeSessionID(MessageContext syCtx) |
void |
Dispatcher.removeSessionID(MessageContext syCtx)
Remove the session Id - To clear out session information from current message
|
void |
HttpSessionDispatcher.removeSessionID(MessageContext syCtx) |
protected void |
AbstractDispatcher.removeSessionID(MessageContext synCtx,
String key) |
void |
SimpleClientSessionDispatcher.unbind(MessageContext synCtx) |
void |
SoapSessionDispatcher.unbind(MessageContext synCtx) |
void |
Dispatcher.unbind(MessageContext synCtx)
Removes the session belonging to the given message context.
|
void |
HttpSessionDispatcher.unbind(MessageContext synCtx) |
void |
SimpleClientSessionDispatcher.updateSession(MessageContext synCtx) |
void |
SoapSessionDispatcher.updateSession(MessageContext synCtx)
As this is a server initiated session, this method will only be called for response messages.
|
void |
Dispatcher.updateSession(MessageContext synCtx)
Updates the session maps.
|
void |
HttpSessionDispatcher.updateSession(MessageContext synCtx)
Searches for "Set-Cookie" HTTP header in the message context.
|
void |
SALSessions.updateSession(MessageContext synCtx,
SessionCookie cookie)
Update or establish a session
|
void |
SALSessions.updateSession(MessageContext synCtx,
String sessionID)
Update or establish a session
|
Modifier and Type | Method and Description |
---|---|
void |
SynapseEventSource.dispatchEvents(MessageContext msgCtx)
Public method for event dispatching, used by the eventPublisher mediator and eventSource
|
boolean |
SynapseEventFilter.isSatisfied(MessageContext mc)
Check the incoming event satisfied with the defined filter
|
Modifier and Type | Method and Description |
---|---|
boolean |
XPathBasedEventFilter.isSatisfied(MessageContext mc) |
Modifier and Type | Method and Description |
---|---|
void |
InboundResponseSender.sendBack(MessageContext messageContext) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
GetPropertyFunction.getSynCtx() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMediator.auditLog(String msg,
MessageContext msgContext)
Deprecated.
This method will be removed in a future version of Synapse.
Please use the
SynapseLog instance returned by
AbstractMediator.getLog(MessageContext) for all logging inside a
mediator. |
protected void |
AbstractMediator.auditWarn(String msg,
MessageContext msgContext)
Deprecated.
This method will be removed in a future version of Synapse.
Please use the
SynapseLog instance returned by
AbstractMediator.getLog(MessageContext) for all logging inside a
mediator. |
boolean |
AbstractMediator.divertMediationRoute(MessageContext synCtx)
This method is invoked when mediation happens in debug mode, branches execution to
the Debug Manager, further behavior is governed by the Debug Manager.
|
void |
MediatorProperty.evaluate(MessageContext synCtx) |
Object |
Value.evaluateObjectValue(MessageContext synCtx) |
String |
Value.evaluateValue(MessageContext synCtx)
Evaluating key based on message context
used when key is a xpath expression
|
Object |
Value.evalutePropertyExpression(MessageContext synCtx) |
String |
MediatorProperty.getEvaluatedExpression(MessageContext synCtx) |
protected MediatorFaultHandler |
AbstractMediator.getLastSequenceFaultHandler(MessageContext synCtx) |
protected SynapseLog |
AbstractMediator.getLog(MessageContext synCtx)
Get a SynapseLog instance appropriate for the given context.
|
protected void |
AbstractMediator.handleException(String msg,
Exception e,
MessageContext msgContext)
Perform an error log message to all logs @ ERROR.
|
protected void |
AbstractMediator.handleException(String msg,
MessageContext msgContext)
Perform an error log message to all logs @ ERROR.
|
protected boolean |
AbstractMediator.isTraceOn(MessageContext msgCtx)
Deprecated.
This method will be removed in a future version of Synapse.
Please use the
SynapseLog instance returned by
AbstractMediator.getLog(MessageContext) for all logging inside a
mediator. |
boolean |
AbstractListMediator.mediate(MessageContext synCtx) |
boolean |
FlowContinuableMediator.mediate(MessageContext synCtx,
ContinuationState continuationState)
Mediate the message using a ContinuationState.
|
boolean |
AbstractListMediator.mediate(MessageContext synCtx,
int mediatorPosition) |
void |
MediatorFaultHandler.onFault(MessageContext synCtx)
Implements the fault handling method for the mediators (basically sequences)
|
void |
AbstractMediator.reportCloseStatistics(MessageContext messageContext,
Integer currentIndex) |
Integer |
AbstractMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Object |
Value.resolveObject(MessageContext synCtx)
Resolve the object defined in the Value
|
void |
AbstractMediator.setEffectiveTraceState(MessageContext synCtx)
This method is used to save previous tracing state and set next the tracing
state for a child mediator
|
protected boolean |
AbstractMediator.shouldCaptureTracing(MessageContext synCtx) |
boolean |
AbstractMediator.shouldTrace(MessageContext msgCtx) |
boolean |
FilterMediator.test(MessageContext synCtx)
Should return true if the sub/child mediators should execute.
|
Constructor and Description |
---|
GetPropertyFunction(MessageContext synCtx) |
MediatorLog(org.apache.commons.logging.Log defaultLog,
boolean traceOn,
MessageContext synCtx) |
MediatorWorker(Mediator seq,
MessageContext synCtx)
Constructor of the MediatorWorker which sets the sequence and the message context
|
MediatorWorker(MessageContext synCtx)
Constructor od the MediatorWorker which sets the provided message context and the
main sequence as the sequence for mediation
|
Modifier and Type | Method and Description |
---|---|
boolean |
SequenceMediator.mediate(MessageContext synCtx)
If this mediator refers to another named Sequence, execute that.
|
boolean |
SynapseMediator.mediate(MessageContext synCtx)
Perform the mediation specified by the rule set
|
boolean |
SequenceMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
void |
SequenceMediator.reportCloseStatistics(MessageContext messageContext,
Integer currentIndex) |
Integer |
SequenceMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Modifier and Type | Method and Description |
---|---|
void |
Target.insert(MessageContext synCtx,
Object object)
Inserts the given object into the target specified by the current Target object.
|
boolean |
BeanMediator.mediate(MessageContext synCtx)
Manipulates a JavaBean attached to the current message context according to the supplied
semantics.
|
Modifier and Type | Method and Description |
---|---|
boolean |
EJBMediator.mediate(MessageContext synCtx)
Calls an external EJB according to the supplied semantics and attaches the result into the
message/message context.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PropertyMediator.mediate(MessageContext synCtx)
Sets a property into the current (local) Synapse Context or into the Axis Message Context
or into Transports Header and removes above properties from the corresponding locations.
|
boolean |
LoopBackMediator.mediate(MessageContext synCtx) |
boolean |
LogMediator.mediate(MessageContext synCtx)
Logs the current message according to the supplied semantics
|
boolean |
CommentMediator.mediate(MessageContext synCtx)
Mediation method.
|
boolean |
ValidateMediator.mediate(MessageContext synCtx) |
boolean |
CallMediator.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
|
boolean |
RespondMediator.mediate(MessageContext synCtx) |
boolean |
SendMediator.mediate(MessageContext synCtx)
This will call the send method on the messages with implicit message parameters
or else if there is an endpoint, with that endpoint parameters
|
boolean |
CalloutMediator.mediate(MessageContext synCtx) |
boolean |
EnqueueMediator.mediate(MessageContext synCtx) |
boolean |
DropMediator.mediate(MessageContext synCtx)
Halts further mediation of the current message by returning false.
|
boolean |
ForEachMediator.mediate(MessageContext synCtx) |
boolean |
ValidateMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
void |
CommentMediator.reportCloseStatistics(MessageContext messageContext,
Integer currentIndex) |
Integer |
CommentMediator.reportOpenStatistics(MessageContext synCtx,
boolean isContentAltering) |
Modifier and Type | Method and Description |
---|---|
protected PreparedStatement |
AbstractDBMediator.getPreparedStatement(Statement stmnt,
Connection con,
MessageContext msgCtx)
Return a Prepared statement for the given Statement object, which is ready to be executed
|
boolean |
AbstractDBMediator.mediate(MessageContext synCtx)
Process each SQL statement against the current message
|
protected void |
DBReportMediator.processStatement(Statement stmnt,
MessageContext msgCtx) |
protected void |
DBLookupMediator.processStatement(Statement stmnt,
MessageContext msgCtx) |
protected abstract void |
AbstractDBMediator.processStatement(Statement query,
MessageContext msgCtx)
Subclasses must specify how each SQL statement is processed
|
Modifier and Type | Method and Description |
---|---|
static void |
EIPUtils.createSynapseEIPTemplateProperty(MessageContext synCtxt,
String templateName,
String paramName,
Object value) |
static void |
EIPUtils.enrichEnvelope(org.apache.axiom.soap.SOAPEnvelope envelope,
org.apache.axiom.soap.SOAPEnvelope enricher,
MessageContext synCtxt,
SynapseXPath expression)
Merge two SOAP envelopes using the given XPath expression that specifies the
element that enriches the first envelope from the second
|
static List<org.apache.axiom.om.OMNode> |
EIPUtils.getDetachedMatchingElements(org.apache.axiom.soap.SOAPEnvelope envelope,
MessageContext synCtxt,
SynapseXPath expression)
Return the set of detached elements specified by the XPath over the given envelope
|
static List |
EIPUtils.getMatchingElements(org.apache.axiom.soap.SOAPEnvelope envelope,
MessageContext synCtxt,
SynapseXPath expression)
Return the set of elements specified by the XPath over the given envelope
|
boolean |
Target.mediate(MessageContext synCtx)
process the message through this target (may be to mediate
using the target sequence, send message to the target endpoint or both)
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
Aggregate.getLastMessage() |
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
Aggregate.getMessages() |
Modifier and Type | Method and Description |
---|---|
boolean |
Aggregate.addMessage(MessageContext synCtx)
Add a message to the interlan message list
|
boolean |
AggregateMediator.mediate(MessageContext synCtx)
Aggregate messages flowing through this mediator according to the correlation criteria
and the aggregation algorithm specified to it
|
boolean |
AggregateMediator.mediate(MessageContext synCtx,
ContinuationState contState) |
Integer |
AggregateMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Modifier and Type | Method and Description |
---|---|
void |
Aggregate.setMessages(List<MessageContext> messages) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
UnboundedMessageQueue.get() |
MessageContext |
MessageQueue.get() |
Modifier and Type | Method and Description |
---|---|
void |
UnboundedMessageQueue.add(MessageContext synCtx) |
void |
MessageQueue.add(MessageContext synCtx) |
boolean |
SamplingThrottleMediator.mediate(MessageContext messageContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
CloneMediator.mediate(MessageContext synCtx)
This will implement the mediate method of the Mediator interface and will provide the
functionality of cloning message into the specified targets and mediation
|
boolean |
IterateMediator.mediate(MessageContext synCtx)
Splits the message by iterating over the results of the given XPath expression
|
boolean |
CloneMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
IterateMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
Integer |
CloneMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Integer |
IterateMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Modifier and Type | Method and Description |
---|---|
ArrayList<org.apache.axiom.om.OMNode> |
Source.evaluate(MessageContext synCtx,
SynapseLog synLog) |
void |
Target.insert(MessageContext synContext,
ArrayList<org.apache.axiom.om.OMNode> sourceNodeList,
SynapseLog synLog) |
boolean |
EnrichMediator.mediate(MessageContext synCtx) |
void |
Target.setProperty(String scope,
MessageContext messageContext,
Object documentElement)
Sets the property value in appropriate message context
|
Modifier and Type | Method and Description |
---|---|
boolean |
EventPublisherMediator.mediate(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
POJOCommandMediator.mediate(MessageContext synCtx)
Implements the mediate method of the Mediator interface.
|
boolean |
AnnotatedCommandMediator.mediate(MessageContext synCtx) |
boolean |
ClassMediator.mediate(MessageContext synCtx)
Don't use a new instance...
|
Modifier and Type | Method and Description |
---|---|
boolean |
InMediator.mediate(MessageContext synCtx)
Executes the list of sub/child mediators, if the filter condition is satisfied
|
boolean |
FilterMediator.mediate(MessageContext synCtx)
Executes the list of sub/child mediators, if the filter condition is satisfied
|
boolean |
SwitchMediator.mediate(MessageContext synCtx)
Iterate over switch cases and find match and execute selected sequence
|
boolean |
OutMediator.mediate(MessageContext synCtx)
Executes the list of sub/child mediators, if the filter condition is satisfied
|
boolean |
InMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
FilterMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
SwitchMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
OutMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
Integer |
InMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Integer |
OutMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
boolean |
InMediator.test(MessageContext synCtx)
Apply mediation only on request messages
|
boolean |
FilterMediator.test(MessageContext synCtx)
Tests the supplied condition after evaluation against the given XPath
or Regex (against a source XPath).
|
boolean |
OutMediator.test(MessageContext synCtx)
Apply mediation only on response messages
|
Modifier and Type | Method and Description |
---|---|
boolean |
ConditionalRouterMediator.mediate(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageStoreMediator.mediate(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
TemplateMediator.mediate(MessageContext synCtx) |
boolean |
InvokeMediator.mediate(MessageContext synCtx) |
boolean |
InvokeMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
void |
TemplateMediator.popFuncContextFrom(MessageContext synCtx) |
void |
TemplateContext.setupParams(MessageContext synCtxt)
evaluate raw parameters passed from an invoke medaiator and store them in this context
|
Modifier and Type | Method and Description |
---|---|
boolean |
TransactionMediator.mediate(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
XSLTMediator.mediate(MessageContext synCtx)
Transforms this message (or its element specified as the source) using the
given XSLT transformation
|
boolean |
FaultMediator.mediate(MessageContext synCtx) |
boolean |
PayloadFactoryMediator.mediate(MessageContext synCtx)
Contains 2 paths - one when JSON Streaming is in use (mediateJsonStreamPayload) and the other for regular
builders (mediatePayload).
|
boolean |
HeaderMediator.mediate(MessageContext synCtx)
Sets/Removes a SOAP header on the current message
|
Modifier and Type | Method and Description |
---|---|
void |
RewriteAction.execute(URIFragments fragments,
MessageContext messageContext) |
boolean |
URLRewriteMediator.mediate(MessageContext messageContext) |
void |
RewriteRule.rewrite(URIFragments fragments,
MessageContext messageContext) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
MessageConsumer.receive()
Receives the next message from the store.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MessageProducer.storeMessage(MessageContext synCtx)
Stores the given message to the store associated with this message consumer.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
Service.fetch(MessageConsumer msgConsumer)
This method has the responsibility of fetching message from the message store.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Service.dispatch(MessageContext msgCtx)
This has the responsibility of dispatching the fetched message from the message store to the client.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
FailoverForwardingService.fetch(MessageConsumer msgConsumer)
Receives the next message from the message store.
|
Modifier and Type | Method and Description |
---|---|
void |
FailoverForwardingService.dispatch(MessageContext messageContext)
Sends the message to a given message store.
|
void |
FailoverForwardingService.sendThroughDeactivateSeq(MessageContext msgCtx)
Sending the out message through the deactivate sequence.
|
void |
FailoverForwardingService.sendThroughFaultSeq(MessageContext msgCtx)
Sending the out message through the fault sequence.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
ForwardingService.fetch(MessageConsumer msgConsumer)
Receives the next message from the message store.
|
Modifier and Type | Method and Description |
---|---|
void |
ForwardingService.dispatch(MessageContext messageContext)
Sends the mesage to a given endpoint.
|
void |
ForwardingService.sendThroughDeactivateSeq(MessageContext msgCtx)
Sending the out message through the deactivate sequence.
|
void |
ForwardingService.sendThroughFaultSeq(MessageContext msgCtx)
Sending the out message through the fault sequence.
|
void |
ForwardingService.sendThroughReplySeq(MessageContext outCtx)
Sending the out message through the reply sequence.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
SamplingService.fetch(MessageConsumer msgConsumer)
Receives the next message from the message store.
|
Modifier and Type | Method and Description |
---|---|
void |
SamplingService.dispatch(MessageContext messageContext)
Sends the message to a given sequence.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
BlockingMsgSender.send(Endpoint endpoint,
MessageContext synapseInMsgCtx) |
Modifier and Type | Method and Description |
---|---|
static void |
BlockingMsgSenderUtils.fillClientOptions(EndpointDefinition endpoint,
org.apache.axis2.client.Options clientOptions,
MessageContext synapseInMsgCtx)
Fill client options extracting properties from the original message context and endpoint
definition
|
static void |
BlockingMsgSenderUtils.fillMessageContext(EndpointDefinition endpoint,
org.apache.axis2.context.MessageContext axisOutMsgCtx,
MessageContext synapseInMsgCtx)
Fill the target message context extracting the required properties of the original message
context and the endpoint
|
MessageContext |
BlockingMsgSender.send(Endpoint endpoint,
MessageContext synapseInMsgCtx) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
MessageStore.get(int index)
Return the Message in given index position
(this may depend on the implementation)
|
MessageContext |
MessageStore.get(String messageId)
Get the Message with the given ID from the Message store without removing it
|
MessageContext |
MessageStore.remove()
Retrieves and removes the first Message in this store.
|
MessageContext |
MessageStore.remove(String messageID)
Delete and return the MessageContext with given Message id
|
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
MessageStore.getAll()
Get the All messages in the Message store without removing them from the queue
|
Modifier and Type | Method and Description |
---|---|
static MessageContext |
MessageConverter.toMessageContext(StorableMessage message,
org.apache.axis2.context.MessageContext axis2Ctx,
MessageContext synCtx)
Converts a message read from the message store to a Synapse Message Context object.
|
Modifier and Type | Method and Description |
---|---|
static MessageContext |
MessageConverter.toMessageContext(StorableMessage message,
org.apache.axis2.context.MessageContext axis2Ctx,
MessageContext synCtx)
Converts a message read from the message store to a Synapse Message Context object.
|
static StorableMessage |
MessageConverter.toStorableMessage(MessageContext synCtx)
Converts a Synapse Message Context to a representation that can be stored in the
Message store queue.
|
Modifier and Type | Method and Description |
---|---|
protected MessageContext |
JDBCMessageStore.deserializeMessage(byte[] msgObj)
Will convert the byte[] message to store-able message.
|
MessageContext |
JDBCMessageStore.get(int position)
Get the message at given position
Only can be done with MYSQL, and no use-case in current implementation
|
MessageContext |
JDBCMessageStore.get(String msgId)
Return the first element with given msg_id
|
MessageContext |
JDBCMessageStore.peek()
Select and return the first element in current table
|
MessageContext |
JDBCConsumer.receive()
Select and return the first element in current table
|
MessageContext |
JDBCMessageStore.remove()
Removes the first element from table
|
MessageContext |
JDBCMessageStore.remove(String msgId)
Remove the message with given msg_id
|
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
JDBCMessageStore.getAll()
Get all messages in the table
|
Modifier and Type | Method and Description |
---|---|
protected Statement |
JDBCMessageStore.getStoreMessageStatement(MessageContext messageContext,
Long sequenceId)
Generates the statement to store message in database.
|
boolean |
JDBCMessageStore.store(MessageContext messageContext)
Add a message to the end of the table.
|
boolean |
JDBCProducer.storeMessage(MessageContext synCtx)
Add a message to the end of the table.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
JmsStore.get(int index) |
MessageContext |
JmsStore.get(String messageId) |
MessageContext |
JmsStore.newSynapseMc(org.apache.axis2.context.MessageContext msgCtx) |
MessageContext |
JmsConsumer.receive() |
MessageContext |
JmsStore.remove()
JMS Message store does not support following operations.
|
MessageContext |
JmsStore.remove(String messageID) |
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
JmsStore.getAll() |
Modifier and Type | Method and Description |
---|---|
boolean |
JmsProducer.storeMessage(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
InMemoryStore.get(int index) |
MessageContext |
InMemoryStore.get(String messageId) |
MessageContext |
InMemoryConsumer.receive() |
MessageContext |
InMemoryStore.remove() |
MessageContext |
InMemoryStore.remove(String messageID) |
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
InMemoryStore.getAll() |
Modifier and Type | Method and Description |
---|---|
boolean |
InMemoryProducer.storeMessage(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
InMemoryProducer |
InMemoryProducer.setDestination(Queue<MessageContext> queue) |
InMemoryConsumer |
InMemoryConsumer.setDestination(Queue<MessageContext> queue) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
RabbitMQStore.get(int index) |
MessageContext |
RabbitMQStore.get(String messageId) |
MessageContext |
RabbitMQStore.newSynapseMc(org.apache.axis2.context.MessageContext msgCtx) |
MessageContext |
RabbitMQConsumer.receive() |
MessageContext |
RabbitMQStore.remove() |
MessageContext |
RabbitMQStore.remove(String messageID) |
Modifier and Type | Method and Description |
---|---|
List<MessageContext> |
RabbitMQStore.getAll() |
Modifier and Type | Method and Description |
---|---|
boolean |
RabbitMQProducer.storeMessage(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
ResequenceMessageStore.peek()
Select and return the first element in current table
|
Modifier and Type | Method and Description |
---|---|
protected Statement |
ResequenceMessageStore.getStoreMessageStatement(MessageContext context,
Long sequenceId)
Stores message in database by providing the correct sequence id.
|
Modifier and Type | Method and Description |
---|---|
static String |
RESTUtils.getFullRequestPath(MessageContext synCtx) |
static String |
RESTUtils.getSubRequestPath(MessageContext synCtx) |
boolean |
Handler.handleRequest(MessageContext messageContext) |
boolean |
Handler.handleResponse(MessageContext messageContext) |
boolean |
RESTRequestHandler.process(MessageContext synCtx)
Attempt to process the given message through one of the available APIs.
|
void |
Resource.registerFaultHandler(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
Resource |
URLMappingBasedDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources) |
Resource |
DefaultDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources) |
Resource |
RESTDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources)
Find a Resource instance suitable for processing the given message
|
Resource |
URITemplateBasedDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources) |
Modifier and Type | Method and Description |
---|---|
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx)
This method does exactly what
MessageHelper.cloneMessageContext(MessageContext) does,
other than cloning the SOAP envelop based on the cloneSOAPEnvelope argument. |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope)
This method will simulate cloning the message context and creating an exact copy of the
passed message.
|
static MessageContext |
MessageHelper.cloneMessageContextForAggregateMediator(MessageContext synCtx) |
Modifier and Type | Method and Description |
---|---|
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx)
This method does exactly what
MessageHelper.cloneMessageContext(MessageContext) does,
other than cloning the SOAP envelop based on the cloneSOAPEnvelope argument. |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope)
This method will simulate cloning the message context and creating an exact copy of the
passed message.
|
static MessageContext |
MessageHelper.cloneMessageContextForAggregateMediator(MessageContext synCtx) |
static void |
ConcurrencyThrottlingUtils.decrementConcurrencyThrottleAccessController(MessageContext synCtx)
Decrement the internal counter for concurrency throttling, in case of normal response retrieval,
delayed response at synapse timeout, exceptional cases while mediation end up trigger fault.
|
static DataHandler |
PayloadHelper.getBinaryPayload(MessageContext mc) |
static SimpleMap |
PayloadHelper.getMapPayload(MessageContext mc) |
static int |
PayloadHelper.getPayloadType(MessageContext mc) |
static org.apache.neethi.Policy |
MessageHelper.getPolicy(MessageContext synCtx,
String propertyKey)
Get the Policy object for the given name from the Synapse configuration at runtime
|
static XMLStreamReader |
PayloadHelper.getStAXPayload(MessageContext mc) |
static String |
PayloadHelper.getTextPayload(MessageContext mc) |
static void |
PayloadHelper.setBinaryPayload(MessageContext mc,
DataHandler dh) |
static void |
PayloadHelper.setMapPayload(MessageContext mc,
SimpleMap map) |
static void |
PayloadHelper.setStAXPayload(MessageContext mc,
XMLStreamReader streamReader) |
static void |
PayloadHelper.setTextPayload(MessageContext mc,
String text) |
static void |
MessageHelper.setWireLogHolderProperties(MessageContext synCtx,
boolean isBreakPoint,
SynapseMediationFlowPoint mediationFlowPoint)
This method is to set mediatorId property to axis2 message context.
|
static void |
PayloadHelper.setXMLPayload(MessageContext mc,
org.apache.axiom.om.OMElement element) |
Modifier and Type | Method and Description |
---|---|
Object |
SynapseXPath.evaluate(Object primaryContext,
MessageContext secondaryContext)
Specialized form of xpath evaluation function.An xpath evaluate() will be performed using two contexts
(ie:-soap-envelope and on Synapse Message Context).
|
String |
SynapseXPath.evaluateDOMXPath(MessageContext synCtx) |
org.apache.axiom.om.OMNode |
SourceXPathSupport.selectOMNode(MessageContext synCtx,
SynapseLog synLog)
Get the first node selected by the configured XPath expression.
|
String |
SynapseXPath.stringValueOf(MessageContext synCtx)
Evaluates the XPath expression against the MessageContext of the current message and
returns a String representation of the result
|
String |
SynapseJsonPath.stringValueOf(MessageContext synCtx) |
Constructor and Description |
---|
DOMSynapseXPathVariableResolver(org.jaxen.VariableContext parentVariableContext,
MessageContext synCtx) |
GetPropertyFunctionResolver(MessageContext synCtx) |
SynapseXPathFunctionContext(org.jaxen.FunctionContext parent,
MessageContext synCtx)
Initialises the function context
|
SynapseXPathVariableContext(org.jaxen.VariableContext parent,
MessageContext synCtx)
Initializes the
SynapseVariableContext with the specified context |
SynapseXPathVariableContext(org.jaxen.VariableContext parent,
MessageContext synCtx,
org.apache.axiom.soap.SOAPEnvelope env)
Initializes the
SynapseVariableContext with the specified envelope |
Modifier and Type | Method and Description |
---|---|
static org.jaxen.Function |
XpathExtensionUtil.getFunctionContext(MessageContext ctxt,
String namespaceURI,
String prefix,
String localName)
Returns a Function Context extension registered for given QName/namespaceURI+prefix+localName
combination
|
org.jaxen.Function |
SynapseXpathFunctionContextProvider.getInitializedExtFunction(MessageContext msgCtxt)
This method should implement instatntiation code for custom xpath function for the registered
QNames given by #getResolvingQName().Note that this extension provider is responsible for
initalizing custom xpath function and returning a fresh function instance to Synapse.
|
Object |
SynapseXpathVariableResolver.resolve(MessageContext msgCtxt)
This method should implement the resolving code for custom xpath variable for the registered
QName given by #getResolvingQName().
|
static Object |
XpathExtensionUtil.resolveVariableContext(MessageContext ctxt,
String namespaceURI,
String prefix,
String localName)
Returns an object resolved by Variable Context extension registered for given
QName/namespaceURI+prefix+localName combination
|
Copyright © 2005–2018 Apache Software Foundation. All rights reserved.