activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Naveen Rawat <nav...@in.effectsoft.com>
Subject Re: How to create a temporary Queue
Date Wed, 23 Aug 2006 08:36:49 GMT

Hi James and Arshad,


I am following this discussion and have some weird things to tell. 


* -  It has been said that a temporary queue vanishes along with the
creating client. But I am getting this unwanted privilge of having it even
after my client ends. How it could be possible?
              
* - And then my server's 
                MessageProducer.send(destination, message);
statements gives an exception like -

. . . . . . . .
. . . . . . . .
. . . . . . . .

INFO  Service                        - Sync error occurred:
javax.jms.JMSException: The destination
temp-queue://e849faa0-746f-4258-a650-ea04231a1082:1 does not exist.
javax.jms.JMSException: The destination
temp-queue://e849faa0-746f-4258-a650-ea04231a1082: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)

1) What could be the reason of this contradiction?


2) Do you like to have a look of the code?




                    THANKS IN ADVANCE


With Regards,
Navin
-- 
View this message in context: http://www.nabble.com/How-to-create-a-temporary-Queue-tf2145190.html#a5940299
Sent from the ActiveMQ - Dev forum at Nabble.com.


Mime
View raw message