You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by misge <mi...@gmail.com> on 2008/05/01 12:41:28 UTC
Temp Queues (JMS)
Hello,
I would like to have an example inside Camel where the destination would be
a tempQueue instead of a predifined Queue.I'm using JBoss and the JBoss
messaging is a part of my constraints.
Any ideas?
I tried from my client by setting the message.setJMSReplyTo(tempQueue)" and
i got the following stacktrace:
13:33:31,750 WARN [DefaultMessageListenerContainer] Execution of JMS
message listener failed
org.apache.camel.RuntimeCamelException:
org.springframework.jms.InvalidDestinationException: This destination does
not exist! QUEUE.JMS_TQ2; nested exception is
javax.jms.InvalidDestinationException: This destination does not exist!
QUEUE.JMS_TQ2
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:73)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:510)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:445)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:414)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:309)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:254)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:871)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:818)
at java.lang.Thread.run(Thread.java:619)
Caused by: org.springframework.jms.InvalidDestinationException: This
destination does not exist! QUEUE.JMS_TQ2; nested exception is
javax.jms.InvalidDestinationException: This destination does not exist!
QUEUE.JMS_TQ2
at
org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:229)
at
org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:172)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:431)
at
org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:475)
at
org.apache.camel.component.jms.EndpointMessageListener.sendReply(EndpointMessageListener.java:160)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:70)
... 8 more
Caused by: javax.jms.InvalidDestinationException: This destination does not
exist! QUEUE.JMS_TQ2
at
org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:407)
at
org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:399)
at
org.jboss.mq.server.JMSServerInterceptorSupport.addMessage(JMSServerInterceptorSupport.java:106)
at
org.jboss.mq.security.ServerSecurityInterceptor.addMessage(ServerSecurityInterceptor.java:168)
at
org.jboss.mq.server.TracingInterceptor.addMessage(TracingInterceptor.java:226)
at
org.jboss.mq.server.JMSServerInvoker.addMessage(JMSServerInvoker.java:112)
at org.jboss.mq.il.jvm.JVMServerIL.addMessage(JVMServerIL.java:101)
at org.jboss.mq.Connection.sendToServer(Connection.java:918)
at
org.jboss.mq.SpyXAResourceManager.addMessage(SpyXAResourceManager.java:113)
at org.jboss.mq.SpySession.sendMessage(SpySession.java:918)
at org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:272)
at org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:206)
at
org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:534)
at
org.apache.camel.component.jms.JmsConfiguration$2.doSend(JmsConfiguration.java:191)
at
org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:511)
at
org.springframework.jms.core.JmsTemplate$2.doInJms(JmsTemplate.java:477)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:428)
... 11 more
--
View this message in context: http://www.nabble.com/Temp-Queues-%28JMS%29-tp16993203s22882p16993203.html
Sent from the Camel - Development mailing list archive at Nabble.com.
Re: Temp Queues (JMS)
Posted by misge <mi...@gmail.com>.
Ok, thanks a lot.
misge wrote:
>
> Hello,
> I would like to have an example inside Camel where the destination would
> be a tempQueue instead of a predifined Queue.I'm using JBoss and the JBoss
> messaging is a part of my constraints.
> Any ideas?
> I tried from my client by setting the message.setJMSReplyTo(tempQueue)"
> and i got the following stacktrace:
> 13:33:31,750 WARN [DefaultMessageListenerContainer] Execution of JMS
> message listener failed
> org.apache.camel.RuntimeCamelException:
> org.springframework.jms.InvalidDestinationException: This destination does
> not exist! QUEUE.JMS_TQ2; nested exception is
> javax.jms.InvalidDestinationException: This destination does not exist!
> QUEUE.JMS_TQ2
> at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:73)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:510)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:445)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:414)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:309)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:254)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:871)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:818)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: org.springframework.jms.InvalidDestinationException: This
> destination does not exist! QUEUE.JMS_TQ2; nested exception is
> javax.jms.InvalidDestinationException: This destination does not exist!
> QUEUE.JMS_TQ2
> at
> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:229)
> at
> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:172)
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:431)
> at
> org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:475)
> at
> org.apache.camel.component.jms.EndpointMessageListener.sendReply(EndpointMessageListener.java:160)
> at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:70)
> ... 8 more
> Caused by: javax.jms.InvalidDestinationException: This destination does
> not exist! QUEUE.JMS_TQ2
> at
> org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:407)
> at
> org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:399)
> at
> org.jboss.mq.server.JMSServerInterceptorSupport.addMessage(JMSServerInterceptorSupport.java:106)
> at
> org.jboss.mq.security.ServerSecurityInterceptor.addMessage(ServerSecurityInterceptor.java:168)
> at
> org.jboss.mq.server.TracingInterceptor.addMessage(TracingInterceptor.java:226)
> at
> org.jboss.mq.server.JMSServerInvoker.addMessage(JMSServerInvoker.java:112)
> at
> org.jboss.mq.il.jvm.JVMServerIL.addMessage(JVMServerIL.java:101)
> at org.jboss.mq.Connection.sendToServer(Connection.java:918)
> at
> org.jboss.mq.SpyXAResourceManager.addMessage(SpyXAResourceManager.java:113)
> at org.jboss.mq.SpySession.sendMessage(SpySession.java:918)
> at
> org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:272)
> at
> org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:206)
> at
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:534)
> at
> org.apache.camel.component.jms.JmsConfiguration$2.doSend(JmsConfiguration.java:191)
> at
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:511)
> at
> org.springframework.jms.core.JmsTemplate$2.doInJms(JmsTemplate.java:477)
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:428)
> ... 11 more
>
--
View this message in context: http://www.nabble.com/Temp-Queues-%28JMS%29-tp16993203s22882p17061218.html
Sent from the Camel - Development mailing list archive at Nabble.com.
Re: Temp Queues (JMS)
Posted by James Strachan <ja...@gmail.com>.
You can now use temp queues using trunk (or the latest snapshot)...
http://activemq.apache.org/camel/jms.html
just use an endpoint called "jms:temp:queue:someName"
then use the endpoint as a source or destination in your camel route.
The other option is if you want to do a request/response to a JMS
queue; if you send an InOut exchange pattern to a JMS endpoint it will
automatically create a temporary queue and use it to consume any
responses.
2008/5/1 misge <mi...@gmail.com>:
>
> Hello,
> I would like to have an example inside Camel where the destination would be
> a tempQueue instead of a predifined Queue.I'm using JBoss and the JBoss
> messaging is a part of my constraints.
> Any ideas?
> I tried from my client by setting the message.setJMSReplyTo(tempQueue)" and
> i got the following stacktrace:
> 13:33:31,750 WARN [DefaultMessageListenerContainer] Execution of JMS
> message listener failed
> org.apache.camel.RuntimeCamelException:
> org.springframework.jms.InvalidDestinationException: This destination does
> not exist! QUEUE.JMS_TQ2; nested exception is
> javax.jms.InvalidDestinationException: This destination does not exist!
> QUEUE.JMS_TQ2
> at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:73)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:510)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:445)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:414)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:309)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:254)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:871)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:818)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: org.springframework.jms.InvalidDestinationException: This
> destination does not exist! QUEUE.JMS_TQ2; nested exception is
> javax.jms.InvalidDestinationException: This destination does not exist!
> QUEUE.JMS_TQ2
> at
> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:229)
> at
> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:172)
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:431)
> at
> org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:475)
> at
> org.apache.camel.component.jms.EndpointMessageListener.sendReply(EndpointMessageListener.java:160)
> at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:70)
> ... 8 more
> Caused by: javax.jms.InvalidDestinationException: This destination does not
> exist! QUEUE.JMS_TQ2
> at
> org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:407)
> at
> org.jboss.mq.server.JMSDestinationManager.addMessage(JMSDestinationManager.java:399)
> at
> org.jboss.mq.server.JMSServerInterceptorSupport.addMessage(JMSServerInterceptorSupport.java:106)
> at
> org.jboss.mq.security.ServerSecurityInterceptor.addMessage(ServerSecurityInterceptor.java:168)
> at
> org.jboss.mq.server.TracingInterceptor.addMessage(TracingInterceptor.java:226)
> at
> org.jboss.mq.server.JMSServerInvoker.addMessage(JMSServerInvoker.java:112)
> at org.jboss.mq.il.jvm.JVMServerIL.addMessage(JVMServerIL.java:101)
> at org.jboss.mq.Connection.sendToServer(Connection.java:918)
> at
> org.jboss.mq.SpyXAResourceManager.addMessage(SpyXAResourceManager.java:113)
> at org.jboss.mq.SpySession.sendMessage(SpySession.java:918)
> at org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:272)
> at org.jboss.mq.SpyMessageProducer.send(SpyMessageProducer.java:206)
> at
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:534)
> at
> org.apache.camel.component.jms.JmsConfiguration$2.doSend(JmsConfiguration.java:191)
> at
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:511)
> at
> org.springframework.jms.core.JmsTemplate$2.doInJms(JmsTemplate.java:477)
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:428)
> ... 11 more
> --
> View this message in context: http://www.nabble.com/Temp-Queues-%28JMS%29-tp16993203s22882p16993203.html
> Sent from the Camel - Development mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://open.iona.com