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 String |
RESTUtils.getFullRequestPath(MessageContext synCtx) |
static String |
RESTUtils.getSubRequestPath(MessageContext synCtx) |
boolean |
Handler.handleRequest(MessageContext messageContext) |
boolean |
Handler.handleResponse(MessageContext messageContext) |
static void |
RESTUtils.populateQueryParamsToMessageContext(MessageContext synCtx)
Populate Message context properties for the query parameters extracted from the url
|
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 |
---|---|
static void |
CORSHelper.handleCORSHeaders(CORSConfiguration corsConfiguration,
MessageContext synCtx,
String supportedMethods,
boolean updateHeaders)
Functions to handle CORS Headers
|
static void |
CORSHelper.handleCORSHeadersForResponse(CORSConfiguration corsConfiguration,
MessageContext synCtx)
Function to set CORS headers to response message transport headers extracting from synapse message context
|
Modifier and Type | Method and Description |
---|---|
Resource |
URLMappingBasedDispatcher.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 |
DefaultDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources) |
Resource |
URITemplateBasedDispatcher.findResource(MessageContext synCtx,
Collection<Resource> resources) |
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 |
---|---|
static void |
SynapseMessageReceiver.doPostInjectUpdates(MessageContext messageContext)
Do the cleanup work, metadata updates in the return path of Message Receiver tread
after injecting the message to the engine
|
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) |
static boolean |
Axis2Sender.preventMultipleResponses(MessageContext messageContext)
This will ensure only one response is sent for a single request.
|
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 |
---|---|
MessageContext |
OAuthConfiguredHTTPEndpoint.retryCallWithNewToken(MessageContext synCtx)
This method is called when we need to retry a call to the resource with a new token
|
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 |
AbstractEndpoint.executeEpTypeSpecificFunctions(MessageContext synCtx) |
void |
HTTPEndpoint.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.
|
String |
EndpointDefinition.getDynamicAddress(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 |
LoadbalanceEndpoint.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 |
RecipientListEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
AbstractEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
Endpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext)
Endpoints that contain other endpoints should implement this method.
|
void |
FailoverEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
AbstractEndpoint.onFault(MessageContext synCtx)
On a fault, propagate to parent if any, or call into the fault handler
|
void |
DefaultEndpoint.onFault(MessageContext synCtx) |
void |
WSDLEndpoint.onFault(MessageContext synCtx) |
void |
AddressEndpoint.onFault(MessageContext synCtx) |
void |
HTTPEndpoint.onFault(MessageContext synCtx) |
protected void |
AbstractEndpoint.prepareForEndpointStatistics(MessageContext synCtx)
Process statistics for this message
|
MessageContext |
OAuthConfiguredHTTPEndpoint.retryCallWithNewToken(MessageContext synCtx)
This method is called when we need to retry a call to the resource with a new token
|
void |
DynamicLoadbalanceEndpoint.send(MessageContext synCtx) |
void |
LoadbalanceEndpoint.send(MessageContext synCtx) |
void |
SALoadbalanceEndpoint.send(MessageContext synCtx) |
void |
RecipientListEndpoint.send(MessageContext synCtx) |
void |
AbstractEndpoint.send(MessageContext synCtx) |
void |
ResolvingEndpoint.send(MessageContext synCtx) |
void |
DefaultEndpoint.send(MessageContext synCtx) |
void |
WSDLEndpoint.send(MessageContext synCtx) |
void |
ServiceDynamicLoadbalanceEndpoint.send(MessageContext synCtx) |
void |
AddressEndpoint.send(MessageContext synCtx) |
void |
Endpoint.send(MessageContext synMessageContext)
Sends the message context according to an endpoint specific behavior.
|
void |
ClassEndpoint.send(MessageContext synCtx) |
void |
FailoverEndpoint.send(MessageContext synCtx) |
void |
IndirectEndpoint.send(MessageContext synCtx)
Send by calling to the real endpoint
|
void |
TemplateEndpoint.send(MessageContext synCtx) |
void |
BasicAuthConfiguredHTTPEndpoint.send(MessageContext synCtx) |
void |
HTTPEndpoint.send(MessageContext synCtx) |
void |
OAuthConfiguredHTTPEndpoint.send(MessageContext synCtx) |
void |
SALoadbalanceEndpoint.sendMessage(MessageContext synCtx) |
void |
RecipientListEndpoint.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. |
void |
TemplateEndpoint.sendMessage(MessageContext synCtx) |
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 |
RoundRobin.getNextEndpoint(MessageContext synCtx,
AlgorithmContext algorithmContext)
Choose an active endpoint using the round robin algorithm.
|
Endpoint |
LoadbalanceAlgorithm.getNextEndpoint(MessageContext synapseMessageContext,
AlgorithmContext algorithmContext)
This method returns the next node according to the algorithm implementation.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthHandler.setAuthHeader(MessageContext messageContext)
This method will set the Authorization header with the relevant auth token.
|
Modifier and Type | Method and Description |
---|---|
void |
BasicAuthHandler.setAuthHeader(MessageContext messageContext) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
MessageCache.removeMessageContext(String id)
Remove a MessageContext from the cache and return it
|
Modifier and Type | Method and Description |
---|---|
void |
MessageCache.addMessageContext(String id,
MessageContext synCtx)
Add a message context to the cache
|
static void |
OAuthUtils.append401HTTPSC(MessageContext synCtx)
Method to append 401 status code to NON_ERROR_HTTP_STATUS_CODES property.
|
protected abstract String |
OAuthHandler.buildTokenRequestPayload(MessageContext messageContext)
Return the request payload relevant to the OAuth handler.
|
protected String |
PasswordCredentialsHandler.buildTokenRequestPayload(MessageContext messageContext) |
protected String |
ClientCredentialsHandler.buildTokenRequestPayload(MessageContext messageContext) |
protected String |
AuthorizationCodeHandler.buildTokenRequestPayload(MessageContext messageContext) |
protected String |
OAuthHandler.getEncodedCredentials(MessageContext messageContext)
Return the base 64 encoded clientId:clientSecret relevant to the OAuth handler.
|
protected String |
OAuthHandler.getRequestParametersAsString(MessageContext messageContext)
Return the request parameters as a string.
|
static String |
OAuthUtils.resolveExpression(String value,
MessageContext messageContext)
This method evaluate the value as an expression or return the value.
|
static boolean |
OAuthUtils.retryOnOAuthFailure(OAuthConfiguredHTTPEndpoint httpEndpoint,
MessageContext synapseInMsgCtx,
MessageContext synapseOutMsgCtx)
Method to check whether retry is needed.
|
void |
OAuthHandler.setAuthHeader(MessageContext messageContext) |
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 |
HttpSessionDispatcher.getSession(MessageContext synCtx)
Check if "Cookie" HTTP header is available.
|
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.
|
void |
HttpSessionDispatcher.removeSessionID(MessageContext syCtx) |
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
|
protected void |
AbstractDispatcher.removeSessionID(MessageContext synCtx,
String key) |
void |
HttpSessionDispatcher.unbind(MessageContext synCtx) |
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.updateSession(MessageContext synCtx)
Searches for "Set-Cookie" HTTP header in the message context.
|
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 |
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 |
SynapseMediator.mediate(MessageContext synCtx)
Perform the mediation specified by the rule set
|
boolean |
SequenceMediator.mediate(MessageContext synCtx)
If this mediator refers to another named Sequence, execute that.
|
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 |
NTLMMediator.mediate(MessageContext messageContext) |
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 |
CommentMediator.mediate(MessageContext synCtx)
Mediation method.
|
boolean |
JSONTransformMediator.mediate(MessageContext synCtx) |
boolean |
EnqueueMediator.mediate(MessageContext synCtx) |
boolean |
RespondMediator.mediate(MessageContext synCtx) |
boolean |
DropMediator.mediate(MessageContext synCtx)
Halts further mediation of the current message by returning false.
|
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 |
PropertyGroupMediator.mediate(MessageContext synCtx)
Sets the properties 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 |
ValidateMediator.mediate(MessageContext synCtx) |
boolean |
ForEachMediator.mediate(MessageContext synCtx) |
boolean |
CalloutMediator.mediate(MessageContext synCtx) |
boolean |
LogMediator.mediate(MessageContext synCtx)
Logs the current message according to the supplied semantics
|
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 |
ValidateMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
void |
CallMediator.postMediate(MessageContext response,
String originalMessageType,
String originalContentType,
Map originalTransportHeaders) |
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 abstract void |
AbstractDBMediator.processStatement(Statement query,
MessageContext msgCtx)
Subclasses must specify how each SQL statement is processed
|
protected void |
DBLookupMediator.processStatement(Statement stmnt,
MessageContext msgCtx) |
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 com.google.gson.JsonElement |
EIPUtils.getJSONElement(MessageContext messageContext,
SynapseJsonPath jsonPath)
Evaluate JSON path and retrieve the result as JsonElement.
|
static com.google.gson.JsonElement |
EIPUtils.getJSONObjectAsElement(MessageContext messageContext,
SynapseJsonPath jsonPath)
Evaluate JSON path and retrieve the result as JsonElement while checking if the evaluated results are
nothing other than JSON objects.
|
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 |
IterateMediator.mediate(MessageContext synCtx)
Splits the message by iterating over the results of the given Path expression
|
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,
ContinuationState continuationState) |
boolean |
CloneMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
Integer |
IterateMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Integer |
CloneMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Modifier and Type | Method and Description |
---|---|
ArrayList<org.apache.axiom.om.OMNode> |
Source.evaluate(MessageContext synCtx,
SynapseLog synLog) |
com.google.gson.JsonElement |
Source.evaluateJson(MessageContext synCtx,
SynapseLog synLog,
com.google.gson.JsonElement sourcePropertyJson)
This method will evaluate a specified source json element.
|
void |
Target.insert(MessageContext synContext,
ArrayList<org.apache.axiom.om.OMNode> sourceNodeList,
SynapseLog synLog) |
void |
Target.insertJson(MessageContext synCtx,
Object sourceJsonElement,
SynapseLog synLog)
This method will insert a provided json element to a specified target.
|
boolean |
EnrichMediator.mediate(MessageContext synCtx) |
void |
Target.removeJsonFromBody(MessageContext synCtx,
SynapsePath jsonPath)
This method will remove all the matching elements of the given jsonPath from the JSON payload in the msg
context.
|
void |
Target.removeJsonFromProperty(MessageContext synCtx,
String property,
SynapsePath jsonPath)
This method will remove all the matching elements of the given jsonPath from the JSON payload in the property
and set the result back to the same property.
|
void |
Target.renameKey(MessageContext synapseContext,
String jsonPath,
String keyName,
String newKeyName)
Renames a json key name at the specified json path with a new key name
|
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 |
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)
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,
ContinuationState continuationState) |
boolean |
OutMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
InMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
boolean |
FilterMediator.mediate(MessageContext synCtx,
ContinuationState continuationState) |
Integer |
OutMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
Integer |
InMediator.reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering) |
boolean |
OutMediator.test(MessageContext synCtx)
Apply mediation only on response messages
|
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).
|
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 |
HeaderMediator.mediate(MessageContext synCtx)
Sets/Removes a SOAP header on the current message
|
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 |
XSLTMediator.mediate(MessageContext synCtx)
Transforms this message (or its element specified as the source) using the
given XSLT transformation
|
Modifier and Type | Method and Description |
---|---|
protected String |
TemplateProcessor.escapeXMLEnvelope(MessageContext msgCtx,
String value)
Escapes XML special characters
|
protected HashMap<String,ArgumentDetails>[] |
TemplateProcessor.getArgValues(String mediaType,
MessageContext synCtx)
Goes through SynapsePath argument list, evaluating each by calling stringValueOf and returns a HashMap String, String
array where each item will contain a hash map with key "evaluated expression" and value "SynapsePath type".
|
protected String |
TemplateProcessor.prepareReplacementValue(String mediaType,
MessageContext synCtx,
Map.Entry<String,ArgumentDetails> replacementEntry)
Preprocess and converty types of the given arg value.
|
abstract String |
TemplateProcessor.processTemplate(String template,
String mediaType,
MessageContext synCtx)
Process the given template and return the output as String
|
String |
FreeMarkerTemplateProcessor.processTemplate(String template,
String mediaType,
MessageContext messageContext) |
String |
RegexTemplateProcessor.processTemplate(String template,
String mediaType,
MessageContext synCtx) |
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()
Receives the next message from the message store.
|
Modifier and Type | Method and Description |
---|---|
void |
ForwardingService.dispatch(MessageContext messageContext)
Sends the message 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()
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
|
void |
BlockingMsgSender.send(EndpointDefinition endpointDefinition,
MessageContext synapseInMsgCtx)
Blocking Invocation
|
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 |
---|---|
InMemoryConsumer |
InMemoryConsumer.setDestination(Queue<MessageContext> queue) |
InMemoryProducer |
InMemoryProducer.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 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) |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope,
boolean isCloneJson)
This method is similar to
MessageHelper.cloneMessageContext(MessageContext, boolean, boolean, boolean)
In order to refactor the code, new method signature was created and this method calls the new method |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope,
boolean isCloneJson,
boolean isAggregate)
This method will simulate cloning the message context and creating an exact copy of the
passed message.
|
static MessageContext |
MessageHelper.cloneMessageContextForAggregateMediator(MessageContext synCtx)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
CallMediatorEnrichUtil.buildMessage(MessageContext synCtx) |
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) |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope,
boolean isCloneJson)
This method is similar to
MessageHelper.cloneMessageContext(MessageContext, boolean, boolean, boolean)
In order to refactor the code, new method signature was created and this method calls the new method |
static MessageContext |
MessageHelper.cloneMessageContext(MessageContext synCtx,
boolean cloneSoapEnvelope,
boolean isCloneJson,
boolean isAggregate)
This method will simulate cloning the message context and creating an exact copy of the
passed message.
|
static MessageContext |
MessageHelper.cloneMessageContextForAggregateMediator(MessageContext synCtx)
Deprecated.
|
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 void |
CallMediatorEnrichUtil.doEnrich(MessageContext synCtx,
Source source,
Target target,
String sourceContentType) |
static DataHandler |
PayloadHelper.getBinaryPayload(MessageContext mc) |
static SynapseLog |
CallMediatorEnrichUtil.getLog(MessageContext synCtx) |
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 |
CallMediatorEnrichUtil.handleException(String msg,
Exception e,
MessageContext msgContext) |
static void |
CallMediatorEnrichUtil.handleException(String msg,
MessageContext msgContext) |
static void |
CallMediatorEnrichUtil.preservetransportHeaders(MessageContext synMsgCtx,
Map originalTransportHeaders) |
static void |
MediatorPropertyUtils.serializeOMElement(MessageContext msgCtx)
This method just serializes the OMElement, when setting a message type, we need to serialize to access the
inner element.
|
static void |
PayloadHelper.setBinaryPayload(MessageContext mc,
DataHandler dh) |
static void |
CallMediatorEnrichUtil.setContentType(MessageContext synCtx,
String targetMessageType,
String targetContentType) |
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) |
Constructor and Description |
---|
SchemaResourceResolver(SynapseConfiguration synCfg,
ResourceMap resourceMap,
MessageContext messageContext) |
Modifier and Type | Method and Description |
---|---|
InputSource |
ResourceMap.resolve(SynapseConfiguration synCfg,
String location,
MessageContext messageContext)
Resolve a resource for a given location.
|
Constructor and Description |
---|
CustomJAXPURIResolver(ResourceMap resourceMap,
SynapseConfiguration synCfg,
MessageContext messageContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SynapseJsonPath.booleanValueOf(MessageContext synCtx)
This method will return the boolean value of the jsonpath.
|
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 |
SynapseJsonPath.stringValueOf(MessageContext synCtx) |
String |
SynapseXPath.stringValueOf(MessageContext synCtx)
Evaluates the XPath expression against the MessageContext of the current message and
returns a String representation of the result
|
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–2023 Apache Software Foundation. All rights reserved.