Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: domain of james.strachan@gmail.com
 designates 66.249.92.197 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references;
        b=pkaYAvoVHL9T58wqSZVOWSCKsIr9zjJkeqBa+hv7FdaE3YC1vW6baMV9+6vNn+nWfyfDym0su7qQo0GuIBJ879B1MXViQleuofTSoukk+XCfbyjOhM+6G3rkW4yAeEbvmw0LWWufbXUK9+p1W3K5eGpEnQBwgnrv8JBWu+03+5g=
Message-ID: <ec6e67fd0603300034h681c076tf3ceac66a3d4c84b@mail.gmail.com>
Date: Thu, 30 Mar 2006 09:34:24 +0100
From: "James Strachan" <james.strachan@gmail.com>
To: activemq-users@geronimo.apache.org
Subject: Re: "Queue is full" problem
In-Reply-To: <200603201758.00531.danielius@elitnet.lt>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline
References: <200603091236.27525.danielius@elitnet.lt>
	 <ABF9032D-8B1A-4B48-8F77-605ADDC82C12@gmail.com>
	 <200603151825.29776.danielius@elitnet.lt>
	 <200603201758.00531.danielius@elitnet.lt>

Have you tried 4.0-RC1 yet?

http://people.apache.org/~chirino/incubator-activemq-4.0-RC1/

it looks like the issue you hit with M4 was a fairly trivial gremlin
caused while trying to register duplicate MBeans in JMX.

James

On 3/20/06, Danielius Jurna <danielius@elitnet.lt> wrote:
> Has anybody taken a look at these problems?
>
> I'd realy like to use ActiveMQ in our project becouse of it's unique feat=
ures,
> but it seems version 4 is not there yet and version 3.2 has this "Queue i=
s
> full" problem, which we cannot afford...
>
> > Several errors I'm getting from ActiveMQ 4.0-M4:
> >
> > 1. On first connect to activemq I'm getting this error on the client
> > (second time everything is fine.:
> > INFO  Service                        - Sync error occurred:
> > javax.management.InstanceAlreadyExistsException:
> > org.apache.activemq:Type=3DQueue,Destination=3DmyQueue,BrokerName=3Dloc=
alhost
> > javax.management.InstanceAlreadyExistsException:
> > org.apache.activemq:Type=3DQueue,Destination=3DmyQueue,BrokerName=3Dloc=
alhost
> >         at
> > com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.ja=
va:4
> >52) at
> > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObjec=
t(De
> >faultMBeanServerInterceptor.java:1410) at
> > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(De=
faul
> >tMBeanServerInterceptor.java:936) at
> > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(Def=
ault
> >MBeanServerInterceptor.java:337) at
> > com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.jav=
a:49
> >7) at
> > org.apache.activemq.broker.jmx.ManagedRegionBroker.register(ManagedRegi=
onBr
> >oker.java:81) at
> > org.apache.activemq.broker.jmx.ManagedQueueRegion.createDestination(Man=
aged
> >QueueRegion.java:55) at
> > org.apache.activemq.broker.region.AbstractRegion.addDestination(Abstrac=
tReg
> >ion.java:76) at
> > org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBro=
ker.
> >java:193) at
> > org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.jav=
a:12
> >3) at
> > org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBrok=
er.j
> >ava:137) at
> > org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.jav=
a:12
> >3) at
> > org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBr=
oker
> >Filter.java:135) at
> > org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.=
java
> >:214) at
> > org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.ja=
va:1
> >94) at
> > org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:3=
09)
> >         at
> > org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.jav=
a:19
> >2) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:107=
) at
> > org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDes=
tina
> >tionBroker.java:97) at
> > org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter=
.jav
> >a:119) at
> > org.apache.activemq.broker.AbstractConnection.processMessage(AbstractCo=
nnec
> >tion.java:336) at
> > org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:=
508)
> >         at
> > org.apache.activemq.broker.AbstractConnection.service(AbstractConnectio=
n.ja
> >va:189) at
> > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportCon=
nect
> >ion.java:60) at
> > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorr=
elat
> >or.java:82) at
> > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter=
.jav
> >a:68) at
> > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormat=
Nego
> >tiator.java:105) at
> > org.apache.activemq.transport.TransportSupport.doConsume(TransportSuppo=
rt.j
> >ava:77) at
> > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:13=
6)
> >         at java.lang.Thread.run(Thread.java:595)
> >
> > 2. First I'm filling queue with as many messages as I can (I manage to =
put
> > about 40000 messages after what my sender blocks - which is normal I
> > guess). Then I start consumer and I get only about 1500 messages, after
> > what my consumer is locked. If I restart my consumer it receives again
> > about 1500 messages and locks. For the consumer I use jencs JCA contain=
er
> > which starts 10 message consumer threads. Seems like a problem in 4.0
> > activemq RA (3.2 was working as expected). Debug logs doesn't give any =
clue
> > (no error, no warning everything seems fine).
> >
> > > On 9 Mar 2006, at 10:36, Danielius Jurna wrote:
> > > > Hello.
> > > >
> > > > I'm running in the "Queue is full" problem (it is mentioned several
> > > > times in
> > > > this mailing list) - when queue is full, activemq stops delivering =
any
> > > > messages.
> > > > I've read, that in 4.0 this problem should be solved, but this
> > > > release is too
> > > > unstable to use in production (null pointer or class cast exception=
s
> > > > occasionaly).
> > >
> > > Could you provide details? FWIW we've fixed the gremlins that caused
> > > ClassCastExceptions after extended periods of time.
> > >
> > > > Any plans to fix that for 3.2?
> > >
> > > No - the "queue is full" problem requires a major rework of the
> > > broker, which is what we did in 4.x
> > >
> > > James
> > > -------
> > > http://radio.weblogs.com/0112098/
>
> --
> ___________________________
> Danielius Jurna
> Senior Software Engineer
> ElitNet UAB
> Draugystes str. 19
> LT-51230 Kaunas, Lithuania
> Phone:  +370 37 352705
> Fax:    +370 37 352718
> e-mail: danielius@elitnet.lt
> http://www.elitnet.lt
>


--

James
-------
http://radio.weblogs.com/0112098/