On 10/18/06, raxlee <[EMAIL PROTECTED]> wrote:
is there any bugs in activemq 4.0.1
there's bugs in every peice of software.. that's why versions keep going up :) if there are lots of message in the queue,how about the performance of the
activemq? James.Strachan wrote: > > could you try 4.0.2? > > On 10/18/06, raxlee <[EMAIL PROTECTED]> wrote: >> >> hi james >> >> i use activemq 4.0.1 >> >> >> James.Strachan wrote: >> > >> > Which version are you using? >> > >> > On 10/18/06, raxlee <[EMAIL PROTECTED]> wrote: >> >> >> >> hi,james >> >> >> >> thank you for your help >> >> >> >> i use the reconnect style for the consumer >> >> >> >> i found some exception stack just now,the error like follow >> >> >> >> 2006-10-15 22:52:21,345 [206.80.72:44689] ERROR >> ManagedRegionBroker >> >> - Failed to register destination queue://com.moloon.s >> >> mschat.server.AllMOQueue >> >> javax.management.InstanceAlreadyExistsException: >> >> >> org.apache.activemq:BrokerName=localhost,Type=Queue,Destination= com.moloon.smschat. >> >> server.AllMOQueue >> >> at >> mx4j.server.MX4JMBeanServer.register(MX4JMBeanServer.java:880) >> >> at >> >> mx4j.server.MX4JMBeanServer.registerImpl(MX4JMBeanServer.java:807) >> >> at >> >> >> mx4j.server.MX4JMBeanServer.registerMBeanImpl(MX4JMBeanServer.java:746) >> >> at >> >> mx4j.server.MX4JMBeanServer.registerMBean(MX4JMBeanServer.java:730) >> >> at >> >> >> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerDestination( ManagedRegionBroker.java:215) >> >> at >> >> >> org.apache.activemq.broker.jmx.ManagedRegionBroker.register( ManagedRegionBroker.java:143) >> >> at >> >> >> org.apache.activemq.broker.jmx.ManagedQueueRegion.createDestination( ManagedQueueRegion.java:57) >> >> at >> >> >> org.apache.activemq.broker.region.AbstractRegion.addDestination( AbstractRegion.java:77) >> >> at >> >> >> org.apache.activemq.broker.region.RegionBroker.addDestination( RegionBroker.java:217) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addDestination( BrokerFilter.java:129) >> >> at >> >> >> org.apache.activemq.advisory.AdvisoryBroker.addDestination( AdvisoryBroker.java:141) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addDestination( BrokerFilter.java:129) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addDestination( BrokerFilter.java:129) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addDestination( BrokerFilter.java:129) >> >> at >> >> >> org.apache.activemq.security.AuthorizationBroker.addDestination( AuthorizationBroker.java:67) >> >> at >> >> >> org.apache.activemq.broker.MutableBrokerFilter.addDestination( MutableBrokerFilter.java:142) >> >> at >> >> >> org.apache.activemq.broker.region.AbstractRegion.addConsumer( AbstractRegion.java:161) >> >> at >> >> >> org.apache.activemq.broker.region.RegionBroker.addConsumer( RegionBroker.java:293) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java :73) >> >> at >> >> >> org.apache.activemq.advisory.AdvisoryBroker.addConsumer( AdvisoryBroker.java:77) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java :73) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java :73) >> >> at >> >> >> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java :73) >> >> at >> >> >> org.apache.activemq.security.AuthorizationBroker.addConsumer( AuthorizationBroker.java:125) >> >> at >> >> >> org.apache.activemq.broker.MutableBrokerFilter.addConsumer( MutableBrokerFilter.java:86) >> >> at >> >> >> org.apache.activemq.broker.AbstractConnection.processAddConsumer( AbstractConnection.java:427) >> >> at >> >> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java :295) >> >> 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) >> >> >> >> >> >> 2006-10-15 22:52:05,994 [48.45.110:37184] INFO Service >> >> - Sync error occurred: java.lang.IllegalStateExceptio >> >> n: Broker has been stopped: >> >> [EMAIL PROTECTED] >> >> java.lang.IllegalStateException: Broker has been stopped: >> >> [EMAIL PROTECTED] >> >> at >> >> >> org.apache.activemq.broker.ErrorBroker.removeConsumer(ErrorBroker.java :140) >> >> at >> >> >> org.apache.activemq.broker.MutableBrokerFilter.removeConsumer( MutableBrokerFilter.java:114) >> >> at >> >> >> org.apache.activemq.broker.AbstractConnection.processRemoveConsumer( AbstractConnection.java:445) >> >> at >> >> org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:63) >> >> 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) >> >> >> >> >> >> before the exception ,the reconnection consumer thread start. >> >> >> >> it seems that,when the connection is interrupted >> abnormally,the >> >> old >> >> consumer of the queue is not destoryed when the connection is >> >> interrupted.that may be the reason of my problem >> >> >> >> why is it? >> >> >> >> can you tell me how to deal with it,how to solve it? >> >> >> >> why the broker can recognize the new consumer as the old one >> who >> >> can't be destoryed? >> >> >> >> can i modify the consumer of reconnection's identifier in >> order >> >> to >> >> avoid the broker recognizing the consumer as the old one? >> >> >> >> many thanks >> >> >> >> -- >> >> View this message in context: >> >> http://www.nabble.com/need-help.Hurry-tf2466053.html#a6874455 >> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> >> >> >> >> > >> > >> > -- >> > >> > James >> > ------- >> > http://radio.weblogs.com/0112098/ >> > >> > >> >> -- >> View this message in context: >> http://www.nabble.com/need-help.Hurry-tf2466053.html#a6874971 >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> >> > > > -- > > James > ------- > http://radio.weblogs.com/0112098/ > > -- View this message in context: http://www.nabble.com/need-help.Hurry-tf2466053.html#a6875951 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
-- Regards, Hiram Blog: http://hiramchirino.com
