The Call mediator is used to send messages out of the ESB to an endpoint.
When you invoke a service, the Call mediator acts in a non-blocking mode, and the underlying worker thread returns without waiting for the response.
Since Call mediator behaves in a synchronous manner, mediation pauses after the service invocation, and resumes from the next mediator in the sequence when the response is received. Call mediator allows you to create your configuration independent from the underlying architecture.
Also, Call mediator leverages the non-blocking transports for better performance. You can obtain the service endpoint for the Call mediator as follows:
- Pick from message-level information
- Pick from a pre-defined endpoint
If you do not specify an endpoint, the Call mediator tries to send the message using the
WSA:TO address of the message. If you specify an endpoint, the Call mediator sends the message based on the specified endpoint.
The endpoint type can be Leaf Endpoint (i.e. Address/WSDL/Default/HTTP) or Group Endpoint (i.e. Failover/Load balance/Recipient list).
The Call mediator is a content-unaware mediator.
Enabling mutual SSL in the blocking mode
When using the Call mediator in the blocking mode (blocking=true), enable the mediator to handle mutual SSL by adding the following JVM settings to the
If the message is to be sent to one or more endpoints, use the following syntax:
endpointreftoken refers to the following:
endpointtoken refers to an anonymous endpoint definition.
Select one of the following options to define the endpoint to which the message should be delivered.
|None||Select this option if you do not want to provide an endpoint. The Call mediator will send the message using its |
|Define Inline||If this is selected, the endpoint to which the message should be sent can be included within the Call mediator configuration. Click Add to add the required endpoint. See Adding an Endpoint for further details.|
|Pick From Registry||If this is selected, the message can be sent to a pre-defined endpoint which is currently saved as a resource in the registry. Click either Configuration Registry or Governance Registry as relevant to select the required endpoint from the resource tree.|
If this is selected, the endpoint to which the message should be sent will be derived via an XPath expression. You are required to enter the relevant XPath expression in the text field that appears when this option is selected.
You can click NameSpaces to add namespaces if you are providing an expression. Then the Namespace Editor panel would appear where you can provide any number of namespace prefixes and URLs used in the XPath expression.
Example 1 - Service orchestration
In this example, the Call mediator invokes a backend service. An Enrich mediator stores the response received for that service invocation.
The Filter Mediator added after the Call mediator carries out a filter to determine whether the first call has been successful. If it is successful, second backend service is invoked. The payload of the request to the second backend is the response of the first service invocation.
After a successful second backend service invocation, response of the first service is retrieved by the Enrich mediator from the property where it was formerly stored. This response is sent to the client by the Respond mediator.
If it is not successful, a custom JSON error message is sent with HTTP 500. If the first call itself is not successful, the output is just sent back with the relevant error code.
Example 2 - Continuing mediation without waiting for responses
In this example, the message will be cloned by the Clone Mediator and sent via the Call mediator. The Drop mediator drops the response so that no further mediation is carried out for the cloned message. However, since the
continueParent attribute of the Clone mediator is set to
true, the original message is mediated in parallel. Therefore, the Log Mediator at the end of the configuration will log the
After call mediator log message without waiting for the Call mediator response.
For another example, see Sample 500: Call Mediator for Non-Blocking Service Invocation.