activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raxlee <800...@sohu.com>
Subject Re: need help.Hurry
Date Wed, 18 Oct 2006 13:14:01 GMT

is there any bugs in activemq 4.0.1

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 <800919@sohu.com> wrote:
>>
>> hi james
>>
>>         i use activemq 4.0.1
>>
>>
>> James.Strachan wrote:
>> >
>> > Which version are you using?
>> >
>> > On 10/18/06, raxlee <800919@sohu.com> 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:
>> >> org.apache.activemq.broker.BrokerService$2@13c59de
>> >> java.lang.IllegalStateException: Broker has been stopped:
>> >> org.apache.activemq.broker.BrokerService$2@13c59de
>> >>         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.


Mime
View raw message