Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of bruce.snyder@gmail.com
 designates 209.85.218.221 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:content-transfer-encoding;
        b=duXB8dkPS6MmdNa0sVuCu0dX8vfqlrzRtnY8pfV/z/RXUzZfr6BYgFNZk88s7naQK/
         J5TS2Nd6AMQW4AFiB30WzneIX6xdjvxBwYlAr2s4NmZV+raeUuvhtYpFVn38uXQsRI5y
         1oiku3QcIbJCNeXSe9t3yLdyqqjAxtmPwo13c=
MIME-Version: 1.0
In-Reply-To: <24634974.post@talk.nabble.com>
References: <24634974.post@talk.nabble.com>
Date: Thu, 23 Jul 2009 15:48:44 -0600
Message-ID: <7b3355cb0907231448r154f1844x858eebcf6ff9cbe0@mail.gmail.com>
Subject: Re: Clearing the message store
From: Bruce Snyder <bruce.snyder@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Thu, Jul 23, 2009 at 3:28 PM, Wxman<Mark.Fenbers@noaa.gov> wrote:
>
> Hi,
>
> My app receives messages that are persisted in the ActiveMQ message store=
.
> This is good except I want to have some control over how many back messag=
es
> my app receives. =A0Any messages older than a specific time are useless. =
=A0I
> want ActiveMQ to deliver only the messages since a specific time. =A0In
> addition, I want ActiveMQ to only hang on to persisted messages for X hou=
rs
> before releasing them. =A0How do I do either of these?
>
> As it is now, it appears ActiveMQ hangs onto them for a very long time, a=
nd
> when I start my app, it immediately receives an ever-growing number of
> messages, which will soon bog down my program...

There are a couple of ways to restrict message delivery based on an
amount of time:

1) Set the message expiration via the MessageProducer.setTimeToLive()
method. This will set the duration of time in milliseconds that a
message should be retained by the broker before being expired. Expired
messages are not delivered to consumers.

2) Use an eviction policy to dispose of messages in broker. More info
on eviction policies is available here:

http://activemq.apache.org/slow-consumer-handling.html

As far as instructing ActiveMQ to persist messages for a given amount
of time, this is not something that's configurable. Persistent
messages are held on to by the broker until they're delivered. Upon
successful delivery, they are then marked for disposal from the
persistent store and are then disposed via a separate thread on a
timed interval (IIRC, it runs every five minutes).

Bruce
--=20
perl -e 'print unpack("u30","D0G)U8V4\@4VYY9&5R\"F)R=3D6-E+G-N>61E<D\!G;6%I=
;\"YC;VT*"
);'

ActiveMQ in Action: http://bit.ly/2je6cQ
Blog: http://bruceblog.org/
Twitter: http://twitter.com/brucesnyder