Hi, I'm after synchronous http request-->jms-endpoint-->http response on the same client connection. I have setup something similar to Sample 264 from v. 3.0.1 in 2.1.3, but can't get the final response back to the original http SOAP client (in my case SOAP UI). So I've verified (debugging) that I get a response back from my ActiveMQ JMS Endpoint, but it just disappears and is never sent back through HTTP to the client.
Here is my synapse.xml: <?xml version="1.0" encoding="UTF-8"?> <syn:definitions xmlns:syn="http://ws.apache.org/ns/synapse";> <syn:endpoint name="xxx/xxx/mytest/jms-sample-JMS/1.0-SNAPSHOT"> <syn:address uri="jms:/ExampleServiceQueue?&transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=queue&JMS_REPLY_TO=dynamicQueues/ExampleServiceReplyQueue&transport.jms.ConnectionFactory=myQueueConnectionFactory"> <syn:suspendOnFailure> <syn:initialDuration>1000</syn:initialDuration> <syn:progressionFactor>1.0</syn:progressionFactor> <syn:maximumDuration>10000</syn:maximumDuration> </syn:suspendOnFailure> </syn:address> </syn:endpoint> <syn:proxy transports="http" trace="enable" name="jms-sample" startOnLoad="true" statistics="enable"> <syn:target outSequence="jms-sample" inSequence="jms-sample" endpoint="xxx/xxx/mytest/jms-sample-JMS/1.0-SNAPSHOT"> <syn:faultSequence> <syn:log level="full"/> <syn:drop/> </syn:faultSequence> </syn:target> <syn:publishWSDL uri="file:registry/xxx/xxx/mytest/myproject-sei/1.0-SNAPSHOT/ExampleService.wsdl"/> <syn:parameter name="transport.jms.ConnectionFactory">myQueueConnectionFactory</syn:parameter> </syn:proxy> <syn:sequence trace="enable" name="jms-sample"> <syn:in> <syn:property scope="axis2" name="JMS_REPLY_TO" value="dynamicQueues/ExampleServiceReplyQueue"/> <syn:property scope="axis2" name="transport.jms.ContentTypeProperty" value="Content-Type"/> </syn:in> <syn:out> <syn:property scope="axis2" name="TRANSPORT_HEADERS" action="remove"/> <syn:send/> </syn:out> </syn:sequence> </syn:definitions> So I get a response back in org.apache.axis2.transport.jms.JMSSender (which I have been debugging as no logs appear from a successful correlationId & replyToDestination Listener read): private void waitForResponseAndProcess(Session session, Destination replyDestination, MessageContext msgCtx, String correlationId, String contentTypeProperty) throws AxisFault { ... Message reply = consumer.receive(timeout); if (reply != null) { //Gets here but there reply is "lost" afterwards This is what is outputted with DEBUG: [2010-12-08 14:40:29,816] DEBUG - SequenceMediator Start : Sequence <jms-sample> [2010-12-08 14:40:29,816] DEBUG - SequenceMediator Sequence <SequenceMediator> :: mediate() [2010-12-08 14:40:29,831] DEBUG - SequenceMediator End : Sequence <jms-sample> [2010-12-08 14:40:29,831] DEBUG - AddressEndpoint Sending message through endpoint : xxx/xxx/mytest/jms-sample-JMS/1.0-SNAPSHOT resolving to address = jms:/ExampleServiceQueue?&transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=queue&JMS_REPLY_TO=dynamicQueues/ExampleServiceReplyQueue&transport.jms.ConnectionFactory=myQueueConnectionFactory [2010-12-08 14:40:29,831] DEBUG - AddressEndpoint SOAPAction: [2010-12-08 14:40:29,831] DEBUG - AddressEndpoint WSA-Action: [2010-12-08 14:41:05,675] DEBUG - JMSConnectionFactory Creating a new JMS Session from JMS CF : myQueueConnectionFactory [2010-12-08 14:41:05,675] DEBUG - JMSConnectionFactory Creating a new JMS MessageProducer from JMS CF : myQueueConnectionFactory [2010-12-08 14:41:05,675] DEBUG - JMSUtils Expecting a response to JMS Destination : ExampleServiceReplyQueue [2010-12-08 14:41:05,675] DEBUG - JMSMessageSender Sent Message Context ID : urn:uuid:1F9ADC7673C92F3D6312997682793206483157169 with JMS Message ID : ID:localhost-3879-1291811958473-0:3:2:1:1 to destination : queue://ExampleServiceQueue [2010-12-08 14:41:05,722] DEBUG - JMSMessageSender Committed local (JMS Session) Transaction [2010-12-08 14:41:07,409] DEBUG - JMSSender Waiting for a maximum of 30000ms for a response message to destination : queue://ExampleServiceReplyQueue with JMS correlation ID : ID:localhost-3879-1291811958473-0:3:2:1:1 Axis2.xml has (both JMSSender and JMSListener are identical): <transportSender name="jms" class="org.apache.axis2.transport.jms.JMSSender"> <parameter name="myTopicConnectionFactory" locked="false"> <parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter> <parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter> <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">TopicConnectionFactory</parameter> <parameter name="transport.jms.ConnectionFactoryType" locked="false">topic</parameter> </parameter> <parameter name="myQueueConnectionFactory" locked="false"> <parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter> <parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter> <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter> <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter> <parameter name="queue.ExampleServiceQueue" locked="false">ExampleServiceQueue</parameter> </parameter> <parameter name="default" locked="false"> <parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter> <parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter> <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter> <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter> <parameter name="queue.ExampleServiceQueue" locked="false">ExampleServiceQueue</parameter> </parameter> </transportSender> -Ilari ________________________________ Disclaimer: This message and any attachments thereto are intended solely for the addressed recipient(s) and may contain confidential information. If you are not the intended recipient, please notify the sender by reply e-mail and delete the e-mail (including any attachments thereto) without producing, distributing or retaining any copies thereof. Any review, dissemination or other use of, or taking of any action in reliance upon, this information by persons or entities other than the intended recipient(s) is prohibited. Thank you.
_______________________________________________ Esb-java-user mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/esb-java-user
