I think that things could be more easy for you if instead of having a "tap" queue, you used a short of cache (e.g. camel-cache).
You could use camel-cache and camel-activemq to store the tap message to the cache and the result message to activemq. >From there you could consume message from activemq, retrieve the message from the cache and then store the message to the database either by using camel-sql, camel-jpa etc. -- *Ioannis Canellos* * FuseSource <http://fusesource.com> ** Blog: http://iocanel.blogspot.com ** Apache Karaf <http://karaf.apache.org/> Committer & PMC Apache ServiceMix <http://servicemix.apache.org/> Committer Apache Gora <http://incubator.apache.org/gora/> Committer *