activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: How to create a temporary Queue
Date Wed, 23 Aug 2006 10:12:29 GMT
It sounds like your server is sending a response to a client which has
already disconnected.


On 8/23/06, ahamad <arashadsaifi@indiatimes.com> wrote:
>
> 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.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message