You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Daryoush Mehrtash <dm...@gmail.com> on 2011/11/14 22:03:13 UTC
Trying to run SOAP over Qpid's JMS
I am trying to replace ActiveMQ messaging with Qpdi in the Apache CXF's
SOAP over JMS demo application without much success. When I try to run
the client, i get: "Cannot consume from a temporary destination created
on another session"
My starting point is the Spring based, CXF demo that uses configuration
based on: http://cxf.apache.org/docs/using-the-jmsconfigfeature.html
I have changed that connection factory and jmsConfig beans to qpid
classes. as below:
> <bean id="jmsConnectionFactory"
> class="org.apache.qpid.client.AMQConnectionFactory">
> <constructor-arg index="0"
> value = "amqp://guest:guest@clientid
> /test?brokerlist='tcp://localhost:5672'"
> />
> </bean>
>
> <bean id="jmsConfig"
> class="org.apache.cxf.transport.jms.JMSConfiguration"
> p:connectionFactory-ref="jmsConnectionFactory"
> p:targetDestination="XXX"/>
> <jaxws:client id="customerService"
> address="jms://"
> serviceClass="com.example.customerservice.CustomerService">
> <jaxws:features>
> <bean class="org.apache.cxf.feature.LoggingFeature" />
> <bean class="org.apache.cxf.transport.jms.JMSConfigFeature"
> p:jmsConfig-ref="jmsConfig" />
> </jaxws:features>
> </jaxws:client>
The same configuration is used on client and server.
When I run the server it all comes up ok. The client appears to send
the message to the server, the server sends its response back, but the
client fails to read the response. Complaining that " Cannot consume from
a temporary destination created on another session"
Any ideas?
This is the client exception that I get:
org.springframework.jms.UncategorizedJmsException: Uncategorized exception
occured during JMS processing; nested exception is javax.jms.JMSException:
Cannot consume from a temporary destination created on another session
at
org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
at
org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469)
at
org.springframework.jms.core.JmsTemplate.receiveSelected(JmsTemplate.java:695)
at org.apache.cxf.transport.jms.JMSConduit.sendExchange(JMSConduit.java:229)
at
org.apache.cxf.transport.jms.JMSOutputStream.doClose(JMSOutputStream.java:56)
at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:192)
at
org.apache.cxf.io.CacheAndWriteOutputStream.postClose(CacheAndWriteOutputStream.java:47)
at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:195)
at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56)
at
org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)
at
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263)
at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:535)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:465)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:368)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:321)
at org.apache.cxf.frontend.ClientProxy.invokeSync(ClientProxy.java:88)
at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:134)
at $Proxy47.getCustomersByName(Unknown Source)
at
com.example.customerservice.client.CustomerServiceTester.testCustomerService(CustomerServiceTester.java:49)
at
com.example.customerservice.client.CustomerServiceSpringClient.main(CustomerServiceSpringClient.java:36)
Caused by: javax.jms.JMSException: Cannot consume from a temporary
destination created on another session
at
org.apache.qpid.client.AMQSession.checkTemporaryDestination(AMQSession.java:2392)
at
org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1978)
at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:987)
at
org.springframework.jms.core.JmsTemplate.createConsumer(JmsTemplate.java:993)
at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:722)
at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:697)
at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:1)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)
Thanks,
Daryoush
Re: Trying to run SOAP over Qpid's JMS
Posted by Daryoush Mehrtash <dm...@gmail.com>.
Thanks, I did get it working. In case if others are
interested..... I am using Spring with the following configuration.
In this set up I have configured "client" and "server" queues and
explicitly configure the "p:replyDestination".
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jaxws="http://cxf.apache.org/jaxws"
xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://cxf.apache.org/core http://cxf.apache.org/schemas/core.xsd
http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd
">
<bean id="jmsConnectionFactory"
class="org.apache.qpid.client.AMQConnectionFactory">
<constructor-arg index="0"
value="amqp://guest:guest@clientid/test?brokerlist='tcp://localhost:5672'" />
</bean>
<bean id="jmsConfig" class="org.apache.cxf.transport.jms.JMSConfiguration"
p:connectionFactory-ref="jmsConnectionFactory" p:targetDestination="server"
p:replyDestination="client" p:messageType="binary" />
<!-- JMS Endpoint -->
<jaxws:endpoint xmlns:customer="http://A URL/"
id="MYServiceJMS" address="jms://"
implementor="MY WEB SERVICE IMPL CLASS">
<jaxws:features>
<!-- <bean class="org.apache.cxf.feature.LoggingFeature" /> -->
<bean class="org.apache.cxf.transport.jms.JMSConfigFeature"
p:jmsConfig-ref="jmsConfig" />
</jaxws:features>
<jaxws:outInterceptors>
<bean class="org.apache.cxf.interceptor.AttachmentOutInterceptor" />
</jaxws:outInterceptors>
<jaxws:properties>
<entry key="mtom-enabled" value="true" />
</jaxws:properties>
</jaxws:endpoint>
</beans>
On Mon, Nov 28, 2011 at 2:58 PM, Robbie Gemmell
<ro...@gmail.com> wrote:
> Hi Daryoush,
>
> DId you manage to get this working? It looks like the Spring or CXF
> code is creating a temporary destination with one session and then
> using it with another, which unfortunately wont work due to the
> clients use of exclusive auto-delete queues under the covers.
>
> If you set a named replyDestination that should help get it going, and
> if you use the Address syntax covered at
> http://qpid.apache.org/books/0.12/Programming-In-Apache-Qpid/html/ch02s04.html
> you should still be able to set it to delete when the consumer is
> closed if required.
>
> Robbie
>
> On 14 November 2011 21:03, Daryoush Mehrtash <dm...@gmail.com> wrote:
>> I am trying to replace ActiveMQ messaging with Qpdi in the Apache CXF's
>> SOAP over JMS demo application without much success. When I try to run
>> the client, i get: "Cannot consume from a temporary destination created
>> on another session"
>>
>> My starting point is the Spring based, CXF demo that uses configuration
>> based on: http://cxf.apache.org/docs/using-the-jmsconfigfeature.html
>>
>> I have changed that connection factory and jmsConfig beans to qpid
>> classes. as below:
>>
>>
>>
>>> <bean id="jmsConnectionFactory"
>>> class="org.apache.qpid.client.AMQConnectionFactory">
>>> <constructor-arg index="0"
>>> value = "amqp://guest:guest@clientid
>>> /test?brokerlist='tcp://localhost:5672'"
>>> />
>>> </bean>
>>>
>>> <bean id="jmsConfig"
>>> class="org.apache.cxf.transport.jms.JMSConfiguration"
>>> p:connectionFactory-ref="jmsConnectionFactory"
>>> p:targetDestination="XXX"/>
>>
>>
>>> <jaxws:client id="customerService"
>>> address="jms://"
>>> serviceClass="com.example.customerservice.CustomerService">
>>> <jaxws:features>
>>> <bean class="org.apache.cxf.feature.LoggingFeature" />
>>> <bean class="org.apache.cxf.transport.jms.JMSConfigFeature"
>>> p:jmsConfig-ref="jmsConfig" />
>>> </jaxws:features>
>>> </jaxws:client>
>>
>>
>> The same configuration is used on client and server.
>>
>> When I run the server it all comes up ok. The client appears to send
>> the message to the server, the server sends its response back, but the
>> client fails to read the response. Complaining that " Cannot consume from
>> a temporary destination created on another session"
>>
>>
>>
>> Any ideas?
>>
>>
>> This is the client exception that I get:
>>
>>
>> org.springframework.jms.UncategorizedJmsException: Uncategorized exception
>> occured during JMS processing; nested exception is javax.jms.JMSException:
>> Cannot consume from a temporary destination created on another session
>> at
>> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
>> at
>> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
>> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469)
>> at
>> org.springframework.jms.core.JmsTemplate.receiveSelected(JmsTemplate.java:695)
>> at org.apache.cxf.transport.jms.JMSConduit.sendExchange(JMSConduit.java:229)
>> at
>> org.apache.cxf.transport.jms.JMSOutputStream.doClose(JMSOutputStream.java:56)
>> at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:192)
>> at
>> org.apache.cxf.io.CacheAndWriteOutputStream.postClose(CacheAndWriteOutputStream.java:47)
>> at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:195)
>> at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56)
>> at
>> org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)
>> at
>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263)
>> at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:535)
>> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:465)
>> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:368)
>> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:321)
>> at org.apache.cxf.frontend.ClientProxy.invokeSync(ClientProxy.java:88)
>> at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:134)
>> at $Proxy47.getCustomersByName(Unknown Source)
>> at
>> com.example.customerservice.client.CustomerServiceTester.testCustomerService(CustomerServiceTester.java:49)
>> at
>> com.example.customerservice.client.CustomerServiceSpringClient.main(CustomerServiceSpringClient.java:36)
>> Caused by: javax.jms.JMSException: Cannot consume from a temporary
>> destination created on another session
>> at
>> org.apache.qpid.client.AMQSession.checkTemporaryDestination(AMQSession.java:2392)
>> at
>> org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1978)
>> at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:987)
>> at
>> org.springframework.jms.core.JmsTemplate.createConsumer(JmsTemplate.java:993)
>> at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:722)
>> at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:697)
>> at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:1)
>> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)
>>
>>
>>
>> Thanks,
>>
>> Daryoush
>>
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>
--
Daryoush
Weblog: http://onfp.blogspot.com/
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Trying to run SOAP over Qpid's JMS
Posted by Robbie Gemmell <ro...@gmail.com>.
Hi Daryoush,
DId you manage to get this working? It looks like the Spring or CXF
code is creating a temporary destination with one session and then
using it with another, which unfortunately wont work due to the
clients use of exclusive auto-delete queues under the covers.
If you set a named replyDestination that should help get it going, and
if you use the Address syntax covered at
http://qpid.apache.org/books/0.12/Programming-In-Apache-Qpid/html/ch02s04.html
you should still be able to set it to delete when the consumer is
closed if required.
Robbie
On 14 November 2011 21:03, Daryoush Mehrtash <dm...@gmail.com> wrote:
> I am trying to replace ActiveMQ messaging with Qpdi in the Apache CXF's
> SOAP over JMS demo application without much success. When I try to run
> the client, i get: "Cannot consume from a temporary destination created
> on another session"
>
> My starting point is the Spring based, CXF demo that uses configuration
> based on: http://cxf.apache.org/docs/using-the-jmsconfigfeature.html
>
> I have changed that connection factory and jmsConfig beans to qpid
> classes. as below:
>
>
>
>> <bean id="jmsConnectionFactory"
>> class="org.apache.qpid.client.AMQConnectionFactory">
>> <constructor-arg index="0"
>> value = "amqp://guest:guest@clientid
>> /test?brokerlist='tcp://localhost:5672'"
>> />
>> </bean>
>>
>> <bean id="jmsConfig"
>> class="org.apache.cxf.transport.jms.JMSConfiguration"
>> p:connectionFactory-ref="jmsConnectionFactory"
>> p:targetDestination="XXX"/>
>
>
>> <jaxws:client id="customerService"
>> address="jms://"
>> serviceClass="com.example.customerservice.CustomerService">
>> <jaxws:features>
>> <bean class="org.apache.cxf.feature.LoggingFeature" />
>> <bean class="org.apache.cxf.transport.jms.JMSConfigFeature"
>> p:jmsConfig-ref="jmsConfig" />
>> </jaxws:features>
>> </jaxws:client>
>
>
> The same configuration is used on client and server.
>
> When I run the server it all comes up ok. The client appears to send
> the message to the server, the server sends its response back, but the
> client fails to read the response. Complaining that " Cannot consume from
> a temporary destination created on another session"
>
>
>
> Any ideas?
>
>
> This is the client exception that I get:
>
>
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception
> occured during JMS processing; nested exception is javax.jms.JMSException:
> Cannot consume from a temporary destination created on another session
> at
> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
> at
> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469)
> at
> org.springframework.jms.core.JmsTemplate.receiveSelected(JmsTemplate.java:695)
> at org.apache.cxf.transport.jms.JMSConduit.sendExchange(JMSConduit.java:229)
> at
> org.apache.cxf.transport.jms.JMSOutputStream.doClose(JMSOutputStream.java:56)
> at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:192)
> at
> org.apache.cxf.io.CacheAndWriteOutputStream.postClose(CacheAndWriteOutputStream.java:47)
> at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:195)
> at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56)
> at
> org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)
> at
> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263)
> at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:535)
> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:465)
> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:368)
> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:321)
> at org.apache.cxf.frontend.ClientProxy.invokeSync(ClientProxy.java:88)
> at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:134)
> at $Proxy47.getCustomersByName(Unknown Source)
> at
> com.example.customerservice.client.CustomerServiceTester.testCustomerService(CustomerServiceTester.java:49)
> at
> com.example.customerservice.client.CustomerServiceSpringClient.main(CustomerServiceSpringClient.java:36)
> Caused by: javax.jms.JMSException: Cannot consume from a temporary
> destination created on another session
> at
> org.apache.qpid.client.AMQSession.checkTemporaryDestination(AMQSession.java:2392)
> at
> org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1978)
> at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:987)
> at
> org.springframework.jms.core.JmsTemplate.createConsumer(JmsTemplate.java:993)
> at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:722)
> at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:697)
> at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:1)
> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)
>
>
>
> Thanks,
>
> Daryoush
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org