Soap routing flow with specific failover handing

[Paweł Wesołowski <pa...@softwaremind.pl>]

Hi all,

I need to create a camel flow, which will do following things:

    * receive soap messages and routes them to a remote web service
      (this is actually done)
    * when the remote web service is not available messages are stored
      in activemq queue where they wait for the service to be up again
    * when the remote web service becomes reachable messages are polled
      from activemq queue, send to web service and soap responses are
      routed back to clients

Checking if the remote web service is up again can be done by 
periodically polling first message from the queue and trying to send it 
to the web service, if some problems occur during this process this 
means that service is still not available.

The hardest part for me is to react correctly when service goes up 
again. How can I run the flow that instantly polls all messages from 
queue when the first one is delivered without any problems? And even 
harder task for me, how can I route the responses back to proper clients?

I am using camel in version 2.2.0.

Flow routing soap messages:

<camelContext id="test_context" 
xmlns="http://camel.apache.org/schema/spring">
<route>
<!-- generic cxf endpoint - receives every soap message -->
<from 
uri="cxf://http://localhost:9000/soaprouter?serviceClass=SOAPMessageProvider" 
/>

<bean ref="soapMesssageToStream" /> <!-- converts SOAPMessage to stream -->

<setHeader 
headerName="CamelHttpMethod"><constant>POST</constant></setHeader>
<to uri="http://remote/service/address />

<process ref="streamToSoapMessage" /> <!-- converts stream to 
SOAPMessage -->
</route>
</camelContext>

--
Paweł Wesołowski