RE: help with jdbc transaction

Andrew,

 

 

The XADataSource:

 

            <bean name="fdcsJdbcDataSource" class="oracle.jdbc.xa.client.OracleXADataSource">

                        <property name="URL" value="${fdcs.database.url}"/>

                        <property name="user" value="${fdcs.database.usr}"/>

                        <property name="password" value="${fdcs.database.pwd}"/>

            </bean>

 

 

The JDBC connector:

 

            <connector name="jdbcFdcsConnectorXA" className="org.mule.providers.jdbc.JdbcConnector">

                        <properties>

                                    <container-property name="dataSource" reference="fdcsJdbcDataSource" required="true"/>

                                    <map name="queries">

                                                <property name="recordWorkIssued" value=

                                                            "INSERT INTO workissued (workorderno, districtcode, issueddate, workgroupcode, sourcefilename)

                                                            VALUES (${DFM_WORKORDER}, ${DFM_DISTRICT_CODE}, to_number(to_char(sysdate, 'YYYYMMDD')), ${DFM_WORKGROUPS},

                                                            ${originalFilename})"/>

                                    </map>

                        </properties>

                        <connection-strategy className="org.mule.providers.SimpleRetryConnectionStrategy">

                                    <properties>

                                                <property name="doThreading" value="true"/>

                                                <property name="retryCount" value="-1"/>

                                                <property name="frequency" value="10000"/>

                                    </properties>

                        </connection-strategy>

            </connector>

 

The endpoint:

 

            <endpoint name="recordWorkIssued" address="jdbc://recordWorkIssued" connector="jdbcFdcsConnectorXA"/>

           

The UMO (the above endpoint is called using UMOEventContext.sendEvent(UMOMessage, UMOEndpoint) depending on logic in the implementation class):

 

            <mule-descriptor name="DFMDispatcherUMO" implementation="ellipseFdcsDispatcher"

                        singleton="false" initialState="started">

 

                        <inbound-router>

                                    <endpoint address="dispatcherInput" connector="jmsInternalXA" synchronous="true">

                                                <transaction action="ALWAYS_BEGIN" factory="org.mule.transaction.XaTransactionFactory"/>

                                    </endpoint>

                        </inbound-router>

 

                        <outbound-router>

                                    <router className="org.mule.routing.outbound.OutboundPassThroughRouter">

                                                <endpoint address="jms://queue.afaria.fdcs-workpack-xml"

                                                            connector="jmsAfariaConnector"

                                                            transformers="DFMMessageToPayloadBytes BytesToString ObjectToJMSMessage"

                                                            synchronous="true"/>

                                    </router>

                        </outbound-router>

 

                        <interceptor name="DFMInterceptorStackXA"/>

 

                        <exception-strategy className="com.amtsybex.dfm.mule.ForwardingComponentExceptionStrategy">

                                    <global-endpoint name="dfmAuditInterceptorXA" transformers="DFMMessageToAuditXML ObjectToJMSMessage"/>

                        </exception-strategy>

 

            </mule-descriptor>