Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of gary.tully@gmail.com
 designates 209.85.218.215 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type;
        b=mA6pLD2uefGRmjGNSDMpBQgEw+gtKFePVL8GpvU94btX9aMCtDDihnu6h0oDs6a8L8
         JbgrTvveVnb8Eg9YMV09OjKm3pcWLwg5WJHfdM9UZXKaBN+tGSYg0uj9lyroI3COPZZj
         AMeYu0dUKcAobbJx/lmhsahltZavXuVUbKG1A=
MIME-Version: 1.0
In-Reply-To: <4B2246FC.1000108@oma.be>
References: <4B2246FC.1000108@oma.be>
Date: Fri, 11 Dec 2009 14:39:36 +0000
Message-ID: <3a73c17c0912110639j369293a9g586047e2613db062@mail.gmail.com>
Subject: Re: activeMQ seems stalled
From: Gary Tully <gary.tully@gmail.com>
To: users@activemq.apache.org
Content-Type: multipart/alternative; boundary=00032555833a98e9f3047a74e462

--00032555833a98e9f3047a74e462
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

sounds like http://activemq.apache.org/producer-flow-control.html - increas=
e
your q usage limits or decrease the system usage to ensure pending message
references are paged to disk. see also :
http://activemq.apache.org/message-cursors.html

2009/12/11 David Delbecq <delbd@oma.be>

> Hello,
>
> we are using an activeMQ server here, as a standalone application and
> used by tomcat, which connects to server using tcp:// protocol.
> Sometimes, the tomcat client is stalled trying to connect to a queue,
> and i have no idea why. Here is a stack dump from tomcat jvm when this
> happen
>
>   java.lang.Thread.State: WAITING (parking)
>        at sun.misc.Unsafe.park(Native Method)
>        - parking to wait for  <3f543bf8> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
>        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:15=
8)
>        at
>
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awa=
it(AbstractQueuedSynchronizer.java:1889)
>        at
> java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:317)
>        at
>
> org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.jav=
a:40)
>        at
>
> org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelat=
or.java:80)
>        at
>
> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.=
java:1233)
>        at
> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1659)
>        - locked <3f5425b8> (a java.lang.Object)
>        at
>
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.=
java:227)
>        at
>
> org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessagePr=
oducerSupport.java:241)
>        at be.rmi.shark.JMSEventManager.sendEvent(JMSEventManager.java:146=
)
>
> It seems that client is waiting forever to receive and answer from MQ
> server. I have several threads in this situation and the only way to
> unlock de situation is to kill and restart the activeMQ server. However,
> the server itself does not loag any error. It looks like the srver
> "forgot" to send response and client is waiting forever. Any idea what
> can cause this? In current situation, we have noticed this happens when
> another client is making bad connection (it connect to activeMQ queues,
> receive an item but neither close connection, nor acknowledge or reject
> the message). Could it be that activeMQ is stalled waiting for
> acknoledge befor allowing other client to add items to queue. Should
> those 2 operations be desynchronzed?
>
> --
> David Delbecq
> ICT
> Institut Royal M=E9t=E9orologique
> Ext:557
>
>
>


--=20
http://blog.garytully.com

Open Source Integration
http://fusesource.com

--00032555833a98e9f3047a74e462--