Fuse 6 is no longer supported
As of February 2025, Red Hat Fuse 6 is no longer supported. If you are using Fuse 6, please upgrade to Red Hat build of Apache Camel.10.5. Deploy and Run the Transactional Route
Overview Copy linkLink copied to clipboard!
Copy linkLink copied to clipboard!
After creating the Derby database instance, you are ready to deploy the OSGi bundles into the container and test the route, as described here.
Steps to deploy and run the transactional route Copy linkLink copied to clipboard!
Copy linkLink copied to clipboard!
Perform the following steps to deploy and run the transactional route in the Red Hat JBoss Fuse OSGi container:
- Create the Derby database instance for the tutorial and create the
accountstable, as follows:- Open a command prompt and change directory to the Derby system directory that you specified earlier (that is, the value of the
derby.system.homesystem property). - Start the Derby database client utility,
ij, by entering the following command:ij
ijCopy to Clipboard Copied! Toggle word wrap Toggle overflow NoteBy default,ijtakes the current working directory to be the Derby system directory. - Create the
txXaTutorialdatabase instance, by entering the followingijcommand:ij> CONNECT 'jdbc:derby:txXaTutorial;create=true';
ij> CONNECT 'jdbc:derby:txXaTutorial;create=true';Copy to Clipboard Copied! Toggle word wrap Toggle overflow - Create the
accountstable and create two sample row entries, by entering the following sequence ofijcommands:ij> CREATE TABLE accounts (name VARCHAR(50), amount INT); ij> INSERT INTO accounts (name,amount) VALUES ('Major Clanger',2000); ij> INSERT INTO accounts (name,amount) VALUES ('Tiny Clanger',100);ij> CREATE TABLE accounts (name VARCHAR(50), amount INT); ij> INSERT INTO accounts (name,amount) VALUES ('Major Clanger',2000); ij> INSERT INTO accounts (name,amount) VALUES ('Tiny Clanger',100);Copy to Clipboard Copied! Toggle word wrap Toggle overflow - Exit
ij, by entering the following command (don't forget the semicolon):ij> EXIT;
ij> EXIT;Copy to Clipboard Copied! Toggle word wrap Toggle overflow
- Open a new command prompt and start the JBoss Fuse OSGi container by entering the following command:
./fuse
./fuseCopy to Clipboard Copied! Toggle word wrap Toggle overflow - Install the
transactionfeature into the OSGi container. Enter the following console command:JBossFuse:karaf@root> features:install transaction
JBossFuse:karaf@root> features:install transactionCopy to Clipboard Copied! Toggle word wrap Toggle overflow - Install the
spring-jdbcfeature into the OSGi container. Enter the following console command:JBossFuse:karaf@root> features:install spring-jdbc
JBossFuse:karaf@root> features:install spring-jdbcCopy to Clipboard Copied! Toggle word wrap Toggle overflow - Install the
derbybundle into the OSGi container. Enter the following console command, replacing the bundle version with whatever version of Derby you are using:JBossFuse:karaf@root> install mvn:org.apache.derby/derby/10.10.1.1
JBossFuse:karaf@root> install mvn:org.apache.derby/derby/10.10.1.1Copy to Clipboard Copied! Toggle word wrap Toggle overflow - Install and start the
derby-dsbundle (assuming that you have already built the bundle, as described in Section 10.3, “Define a Derby Datasource”) by entering the following console command:JBossFuse:karaf@root> install -s mvn:org.fusesource.example/derby-ds/1.0-SNAPSHOT
JBossFuse:karaf@root> install -s mvn:org.fusesource.example/derby-ds/1.0-SNAPSHOTCopy to Clipboard Copied! Toggle word wrap Toggle overflow - To check that the datasources have been successfully exported from the
derby-dsbundle, list thederby-dsservices using theosgi:lscommand. For example, given that BundleID is the bundle ID for thederby-dsbundle, you would enter the following console command:JBossFuse:karaf@root> osgi:ls BundleID
JBossFuse:karaf@root> osgi:ls BundleIDCopy to Clipboard Copied! Toggle word wrap Toggle overflow Amongst the exported services, you should see an entry like the following:Copy to Clipboard Copied! Toggle word wrap Toggle overflow This is the wrapped XA datasource (recognizable from thearies.xa.aware = truesetting), which is automatically created by the Aries wrapper feature (see Apache Aries Auto-Enlisting XA Wrapper). - Install and start the
tx-xabundle, by entering the following console command:JBossFuse:karaf@root> install -s mvn:org.fusesource.example/tx-xa
JBossFuse:karaf@root> install -s mvn:org.fusesource.example/tx-xaCopy to Clipboard Copied! Toggle word wrap Toggle overflow - Create a file called
giro1.xmlin any convenient directory and use a text editor to add the following message contents to it:Copy to Clipboard Copied! Toggle word wrap Toggle overflow Now copygiro1.xmlinto the PathNameToMsgDir directory you created earlier (see Section 10.4, “Define a Transactional Route”). Thegiro1.xmlfile should disappear immediately after it is copied, because the PathNameToMsgDir is being monitored by the feeder route. - Use the JMX console to see what has happened to the message in
giro1.xml. Open a new command prompt and enter the following command (provided with the standard JDK):jconsole
jconsoleCopy to Clipboard Copied! Toggle word wrap Toggle overflow In the JConsole: New Connection screen, select theorg.apache.karaf.main.Mainlocal process and click Connect. - Click on the MBean tab and use the tree in the left-hand column to navigate to org.apache.activemq | TxXaDemo | Queue | statusLog | Operations, as shown in the following screenshot.
Figure 10.1. JMX Operations Supported by the statusLog Queue
- Now in the right hand pane of the JConsole window, click
browse(the version of the method that takes no arguments). The Operation return value dialog pops up as shown , which enables you to browse all of the messages currently pending in thestatusLogqueueue.Figure 10.2. JMX Browsing the statusLog Queue
In the example shown here, there is just one message in the queue. If you scroll down, you can see the Text field, which holds the body of the JMS message. The body contains the most recent result of calling theAccountService.dumpTable()method (which is called in the last step of the transactional route). - You can also force a transaction rollback by sending a message that exceeds the
AccountService.debit()limit (withdrawal limit) of 100. For example, create the filegiro2.xmland add the following message contents to it:Copy to Clipboard Copied! Toggle word wrap Toggle overflow When you copy this file into the PathNameToMsgDir directory, the message never propagates through to thestatusLogqueue, because the transaction gets rolled back.