The problem was that in my junit test, the message was sometimes sent before the subscription was created, so the subscriber would not receive the sent message at all.
On Mon, Jul 14, 2008 at 2:29 PM, sandeep reddy <[EMAIL PROTECTED]> wrote: > > Thanks, > > Finally got it working. Please find my comments below. > > > gnodet wrote: >> >> Sorry again. My test had transient failures, as the durable >> subscription was not always created before the message was actually >> sent, so it was sometimes failing. So I can confirm it works for >> cacheLevels of 1, 2 or 3 ..." >> > > Can you explain the statement. By the "transient failures" did you mean that > the subscription may fail sometimes ? > > Also we noted that it works for the first time. If we redeploy the same SA > we get following error: > > INFO - AutoDeploymentService - Directory: hotdeploy: Finished > installation of archive: updateprofile-sa-3.2.1.jar > dddddddddddddddddddddddddddddddddddddddddddPortal > INFO - DefaultMessageListenerContainer - Could not refresh JMS Connection - > retrying in 5000 ms > javax.jms.InvalidClientIDException: Broker: localhost - Client: Portal > already connected > at > org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:204) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82) > at > org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:70) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82) > at > org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:92) > at > org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:706) > at > org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86) > at > org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:121) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137) > at java.lang.Thread.run(Thread.java:595) > dddddddddddddddddddddddddddddddddddddddddddDirector > INFO - DefaultMessageListenerContainer - Could not refresh JMS Connection - > retrying in 5000 ms > javax.jms.InvalidClientIDException: Broker: localhost - Client: Director > already connected > at > org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:204) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82) > at > org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:70) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82) > at > org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:92) > at > org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:706) > at > org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86) > at > org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:121) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137) > at java.lang.Thread.run(Thread.java:595) > > Thanks again. > Sandeep > > -- > View this message in context: > http://www.nabble.com/Probable-BUG-for-new-jms-endpoints-tp18396993p18442872.html > Sent from the ServiceMix - User mailing list archive at Nabble.com. > > -- Cheers, Guillaume Nodet ------------------------ Blog: http://gnodet.blogspot.com/
