Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 87298 invoked from network); 18 Oct 2006 11:38:08 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 18 Oct 2006 11:38:08 -0000 Received: (qmail 77749 invoked by uid 500); 18 Oct 2006 11:38:07 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 77729 invoked by uid 500); 18 Oct 2006 11:38:07 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 77720 invoked by uid 99); 18 Oct 2006 11:38:07 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Oct 2006 04:38:07 -0700 X-ASF-Spam-Status: No, hits=1.9 required=10.0 tests=FROM_ALL_NUMS,SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: domain of lists@nabble.com designates 72.21.53.35 as permitted sender) Received: from [72.21.53.35] (HELO talk.nabble.com) (72.21.53.35) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Oct 2006 04:38:06 -0700 Received: from [72.21.53.38] (helo=jubjub.nabble.com) by talk.nabble.com with esmtp (Exim 4.50) id 1Ga9k1-0007aM-UC for activemq-users@geronimo.apache.org; Wed, 18 Oct 2006 04:37:45 -0700 Message-ID: <6874303.post@talk.nabble.com> Date: Wed, 18 Oct 2006 04:37:45 -0700 (PDT) From: raxlee <800919@sohu.com> To: activemq-users@geronimo.apache.org Subject: Re: the consumer cant't receive message from the activemq broker In-Reply-To: MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: 800919@sohu.com References: <6873607.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N 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 James.Strachan wrote: > > Could you try use 4.0.2 and see if you can reproduce these issues - > some issues were fixed to do with consumers reconnecting causing > problems. > > On 10/18/06, raxlee <800919@sohu.com> wrote: >> >> hello.all >> i run a activemq on linux os,the version of activemq is >> v4.0.1.i >> use the queue form .and tcp for transaction >> i just start one broker supply the service to many producers and >> consumers. >> when i run a activemq test programme.the process for producer >> and >> consumer is with high speed. >> but when i run my server use the activemq.after the system >> running >> several days,i found that the >> consumers receive the message from the activemq with low >> speed.however,the consumer can't receive any >> message despite there is many message remain in the queue.the >> consumers can receive the message >> again when i restart the activemq server. >> i found another question:after the producer sending many >> messages,i >> try to close the connection.and then i >> reconnect the activemq broker,the consumer can't receive the >> remain >> message in the queue.why? >> >> i don't konw what causes that.my server is not busy from the cpu >> info and the memory. >> my activemq.xml like the follow >> >> >> >> >> >> > class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> > admin="admins" /> >> > read="users" write="users" admin="users" /> >> > admin="users" /> >> > admin="admins" /> >> > read="users" write="users" admin="users" /> >> > admin="users" /> >> >> > read="guests,users" write="guests,users" admin="guests,users"/> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> > dataDirectory="${activemq.home}/activemq-data"/> >> >> >> >> >> >> > uri="tcp://localhost:61616?wireFormat.maxInactivityDuration=30000" /> >> >> >> >> >> >> >> >> >> >> >> >> >> my producer.java like follow >> >> >> >> many thanks >> -- >> View this message in context: >> http://www.nabble.com/the-consumer-cant%27t-receive-message-from-the-activemq-broker-tf2465777.html#a6873607 >> 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/the-consumer-cant%27t-receive-message-from-the-activemq-broker-tf2465777.html#a6874303 Sent from the ActiveMQ - User mailing list archive at Nabble.com.