Introduction to Message Stores¶
This sample demonstrates the basic functionality of a message store.
Synapse configuration¶
Following are the artifact configurations that we can use to implement this scenario. See the instructions on how to build and run this example.
<proxy xmlns="http://ws.apache.org/ns/synapse" name="SampleProxy" transports="http" startOnLoad="true" trace="disable">
<description/>
<target>
<inSequence>
<log level="full"/>
<property name="FORCE_SC_ACCEPTED" value="true" scope="axis2"/>
<store messageStore="MyStore" sequence="onStoreSequence"/>
</inSequence>
<faultSequence>
<sequence key="OnError"/>
</faultSequence>
</target>
</proxy>
<sequence xmlns="http://ws.apache.org/ns/synapse" name="onStoreSequence">
<log>
<property name="On-Store" value="Storing message"/>
</log>
</sequence>
<messageStore xmlns="http://ws.apache.org/ns/synapse" name="MyStore" />
<sequence xmlns="http://ws.apache.org/ns/synapse" name="OnError">
<log level="full">
<property name="MESSAGE" value="Executing default 'fault' sequence"/>
<property name="ERROR_CODE" expression="get-property('ERROR_CODE')"/>
<property name="ERROR_MESSAGE" expression="get-property('ERROR_MESSAGE')"/>
</log>
<drop/>
</sequence>
Build and run¶
Create the artifacts:
- Set up WSO2 Integration Studio.
- Create an integration project with an ESB Configs module and an Composite Exporter.
- Create the proxy service, message store, and mediation sequences with the configurations given above.
- Deploy the artifacts in your Micro Integrator.
Send the following request to invoke the service:
POST http://localhost:9090/services/SampleProxy HTTP/1.1
Accept-Encoding: gzip,deflate
Content-Type: text/xml;charset=UTF-8
SOAPAction: "urn:getQuote"
Content-Length: 492
Host: localhost:9090
Connection: Keep-Alive
User-Agent: Apache-HttpClient/4.1.1 (java 1.5)
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ser="http://services.samples" xmlns:xsd="http://services.samples/xsd">
<soapenv:Header/>
<soapenv:Body>
<ser:getQuote xmlns:ser="http://services.samples" xmlns:xsd="http://services.samples/xsd">
<ser:request>
<xsd:symbol>IBM</xsd:symbol>
</ser:request>
</ser:getQuote>
</soapenv:Body>
</soapenv:Envelope>
In the proxy service, the store mediator will store the
getQuote
request message in the
MyStore
message store. Before storing the request,
the message store mediator will invoke the
onStoreSequence
sequence.
Analyze the logs and you will see the following log:
INFO {org.apache.synapse.mediators.builtin.LogMediator} - To: /services/SampleProxy, WSAction: urn:getQuote, SOAPAction: urn:getQuote, MessageID: urn:uuid:ab78ee5d-f5ed-4346-a0ea-1beb2e6c0b1d, Direction: request, On-Store = Storing message
You can then use the JMX view of the Synapse message store using jconsole.
Top