HTTP to JMS, and synchronous request with response.

Ruwan,

Thanks excellent news that you are writing one already..

Will that be available via the SVN repo or will that be posted to the esbsite.org?

Thanks,
J

ruwan,



I was able to get cloning to work as you described, but as jdholmes1978 mentioned, it will consume more memory, but more importantly, it doesn't guarantee that the message ever got to the queue.



I was looking at the source for org.apache.synapse.transport.jms.JMSSender, and noticed that JMS_MESSAGE_ID property is getting set.  Further searches reveal that another user may be struggling with this same issue as I.  See j0na's post on April 18 here: http://wso2.org/forum/thread/3498  and more explanation on nabble,  http://www.nabble.com/How-take-the-JMS_MESSAGE_ID-td17536304.html



What I need to do is figure out a way to take that property, and return it to the client that made the initial request.  At first I was hoping to apply some quick scripting in an outSequence (http://esbsite.org/resources.jsp?path=/summaries/wkeenan/Groovy%20Script%20stored%20in%20a%20Repository%20snippet), but apparently, the outSequence never runs, ostensibly because there is no message to apply the outSequence to get it started?!



So if the inSequence is finished, and the outSequence is 'waiting', then that leaves me with trying to apply some change to my endpoint.  Is there some way to configure my endpoint to pick up that JMS_MESSAGE_ID after the message is sent to the queue?  Here is my basic proxy:

  <syn:proxy name="ResponseProxy" transports="http" startOnLoad="true">

    <syn:target>

      <syn:endpoint>

        <syn:address uri="jms:/testQueue?transport.jms.ConnectionFactory=myQueueConnectionFactory">

          <syn:timeout>

            <syn:duration>10</syn:duration>

            <syn:action>fault</syn:action>

          </syn:timeout>

        </syn:address>

      </syn:endpoint>

      <syn:inSequence>

        <syn:property name="OUT_ONLY" value="true"/>

        <syn:property name="RESPONSE" value="true"/>

        <syn:header name="To" action="remove"/>

      </syn:inSequence>

      <syn:outSequence>

        <syn:script language="groovy">

          <![CDATA[

              static void mediate(mc)

              {

                def payloadXML = "<response>";

                payloadXML += "Message received for processing and given the following id: ";

                payloadXML += mc.getProperty("JMS_MESSAGE_ID")

                payloadXML += "</response>";

                mc.setPayloadXML(payloadXML);

                mc.setResponse(true);

              }

              ]]>

        </syn:script>       

        <syn:send/>

      </syn:outSequence>

    </syn:target>

  </syn:proxy> 

-K