activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bruce Snyder <>
Subject Re: Clearing the message store
Date Thu, 23 Jul 2009 21:48:44 GMT
On Thu, Jul 23, 2009 at 3:28 PM, Wxman<> 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 messages
> my app receives.  Any messages older than a specific time are useless.  I
> want ActiveMQ to deliver only the messages since a specific time.  In
> addition, I want ActiveMQ to only hang on to persisted messages for X hours
> before releasing them.  How do I do either of these?
> As it is now, it appears ActiveMQ hangs onto them for a very long time, and
> 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:

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).

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

ActiveMQ in Action:

View raw message