activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ahamad <arashadsa...@indiatimes.com>
Subject Re: How to create a temporary Queue
Date Wed, 23 Aug 2006 09:59:34 GMT

Hi James,
    Thanks for giveing me the idea, I create request/responce client for AMQ
according to the link which is refered by you. but at the sever(receiver)
side it gives the following error on the broker side whenever
producer.send(request.getJMSReplyTo(), response) statement comes..

INFO  Service                        - Sync error occurred:
javax.jms.JMSException: The destination
temp-queue://84f373b0-5f62-4da3-ac05-f19a378cd628:1 does not exist.
javax.jms.JMSException: The destination
temp-queue://84f373b0-5f62-4da3-ac05-f19a378cd628:1 does not exist.
        at
org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:249)
        at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:224)
        at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:348)
        at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
        at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:113)
        at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
        at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:113)
        at
org.apache.activemq.broker.UserIDBroker.send(UserIDBroker.java:38)
        at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:126)
        at
org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:351)
        at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:590)
        at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
        at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
        at java.lang.Thread.run(Thread.java:534)

what is wrong?  Is any mistake from my side Pls correct it.

>
> Hi James,
>
> >
> >On 8/23/06, ahamad <arashadsaifi@indiatimes.com> wrote:
> >>
> >> Hi James,
> >>      I wants to know the openwire API.
>
> >Which language? (See the createTemporaryQueue() in CMS or NMS)
>
> I am working on CMS, So pls tell me how to use temporary queue?

>As I said before - once you create it you use it like any other
>Destination like a Queue or Topic


> createTemporaryQueue() return the destenation and then how to use this
> destenation for sending the request/responce?. pls help me .....

>For sending use MessageProducer.send(destination, message).

>To implement request-response see this FAQ entry...

>http://incubator.apache.org/activemq/how-should-i-implement-request-response-with-jms.html

>-- 

>James

Thanks
Arashad
-- 
View this message in context: http://www.nabble.com/How-to-create-a-temporary-Queue-tf2145190.html#a5941402
Sent from the ActiveMQ - Dev forum at Nabble.com.


Mime
View raw message