...
This sample demonstrates the use of the Transaction Mediator using a sample distributed transaction. For information the mediator, refer to section In this sample, a record is delete from one database and added to a second database. If either of the operations (deleting from the first database and adding to the other) fails, all operations will roll back, and the records will be untouched.
Also, see Transaction Mediator.
Prerequisites
Refer For a list of prerequisites, refer to Prerequisites section in ESB samples setup page.
...
1. First, let's take a look at the synapse configuration for the ESB used for this sample. We have given a sample below:
| Code Block | ||||
|---|---|---|---|---|
| ||||
<definitions xmlns="http://ws.apache.org/ns/synapse"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://ws.apache.org/ns/synapse http://synapse.apache.org/ns/2010/04/configuration/synapse_config.xsd">
<sequence name="myFaultHandler">
<log level="custom">
<property name="text" value="** Rollback Transaction**"/>
</log>
<transaction action="rollback"/>
<send/>
</sequence>
<sequence name="main" onError="myFaultHandler">
<in>
<send>
<endpoint>
<address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
</endpoint>
</send>
</in>
<out>
<transaction action="new"/>
<log level="custom">
<property name="text" value="** Reporting to the Database esbdb**"/>
</log>
<dbreport useTransaction="true" xmlns="http://ws.apache.org/ns/synapse">
<connection>
<pool>
<dsName>jdbc/XADerbyDS</dsName>
<user>synapse</user>
<password>synapse</password>
</pool>
</connection>
<statement>
<sql>delete from company where name =?</sql>
<parameter expression="//m0:return/m1:symbol/child::text()"
xmlns:m0="http://services.samples"
xmlns:m1="http://services.samples/xsd"
type="VARCHAR"/>
</statement>
</dbreport>
<log level="custom">
<property name="text" value="** Reporting to the Database esbdb1**"/>
</log>
<dbreport useTransaction="true" xmlns="http://ws.apache.org/ns/synapse">
<connection>
<pool>
<dsName>jdbc/XADerbyDS1</dsName>
<user>synapse</user>
<password>synapse</password>
</pool>
</connection>
<statement>
<sql>INSERT into company values ('IBM','c4',12.0)</sql>
</statement>
</dbreport>
<transaction action="commit"/>
<send/>
</out>
</sequence>
</definitions>
|
...
| Code Block |
|---|
ant stockquote -Daddurl=http://localhost:9000/services/SimpleStockQuoteService -Dtrpurl=http://localhost:8280/ -Dsymbol=SUN/ |
In this sample, You can try deleting a record is delete from one database and added adding to a second database. If either of the operations (deleting from the first database and adding to the other) fails, all operations will Simulate a failure scenario and notice how all operations roll back, and none of the records will be untouchedgets affected.