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 christian.posta@gmail.com
 designates 209.85.217.180 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <443BCE38E921434394B45FF0813FA578053E9763@MSGEXSV21106.ent.wfb.bank.corp>
References: 
 <443BCE38E921434394B45FF0813FA578053E8A34@MSGEXSV21106.ent.wfb.bank.corp>
	<CAKS7T5N+9PQYKR+Kh37KfjqWzwhaDe2Fwuo582vURsvZqnLbQA@mail.gmail.com>
	<443BCE38E921434394B45FF0813FA578053E9763@MSGEXSV21106.ent.wfb.bank.corp>
Date: Fri, 22 Nov 2013 08:22:49 -0700
Message-ID: 
 <CAKS7T5ODg4SEaQ+6sSwaYiGezHg=wvm2RkSYC7dtEw-t3zcNzw@mail.gmail.com>
Subject: Re: Producer Flow Block - Consumer Deadlock after max memory limits
 exceeded
From: Christian Posta <christian.posta@gmail.com>
To: "users@activemq.apache.org" <users@activemq.apache.org>
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

Right. It means that particular file that holds the message cannot be
deleted/archived.


On Fri, Nov 22, 2013 at 6:48 AM,  <barry.barnett@wellsfargo.com> wrote:
> If there is a 'useful' artificat in the journal which is 'tied' to a mess=
age on the DLQ, that means the journal can't be cleared, right?  The only w=
ay to clear the journal is to delete the message from the DLQ first, correc=
t?
>
> Regards,
>
> Barry Barnett
> WMQ Enterprise Services & Solutions
> Wells Fargo
> Cell: 704-564-5501
>
> -----Original Message-----
> From: Christian Posta [mailto:christian.posta@gmail.com]
> Sent: Thursday, November 21, 2013 6:13 PM
> To: users@activemq.apache.org
> Subject: Re: Producer Flow Block - Consumer Deadlock after max memory lim=
its exceeded
>
> Inline...
>
> On Thu, Nov 21, 2013 at 10:51 AM,  <barry.barnett@wellsfargo.com> wrote:
>> Version: Active MQ v5.8
>> Embedded Broker, Producer, Consumer all within same JVM
>>
>> If max memory limits are set to 320MB, which equates to 10 journal files=
 (32MB per file), the files cannot be cleared even if there is 1 message on=
 the DLQ.
>
> So you might need to post your config (or show the code for your config i=
f embedded). "Memory Limits" set to 320MB isn't the same thing as "Store Li=
mits" set to 320MB with 32MB journal files. Individual files will be cleare=
d out if there are no useful artifacts in them (messages, durable subscript=
ion info, producer audit data structures, etc...). The default cleanup peri=
od is 30s:
>
> eg:
>
> <kahaDB cleanupInterval=3D"30000" ..>
>
>
>
>>This 1 message blocks the freeing up of the journal file where it resides=
.  In order to resolve this, the JVM is >recycled.  I'm sure there is a bet=
ter way of resolving this issue.  Any advice?
>
> Are producer/consumer using same connection? What ack mode is your consum=
er using?
>
> Since this is embedded (broker,producer,consumer) it should be easy enoug=
h to extract out the salient points and put together a unit test.
> If you provide something concrete like that, I can take a look and tell y=
ou exactly what's happening.
>
>
>>
>> Regards,
>>
>> Barry Barnett
>> WMQ Enterprise Services & Solutions
>> Wells Fargo
>> Cell: 704-564-5501
>>
>>
>>
>
>
>
> --
> Christian Posta
> http://www.christianposta.com/blog
> twitter: @christianposta


--=20
Christian Posta
http://www.christianposta.com/blog
twitter: @christianposta