Expire messages on topics

["Ericsson Jonas (3) (Consultant)" <jo...@wirelesscar.com>]

Hi,

Background:
We have a handful of topics, the messages sent to them will have a TTL on 1s.
To make the test cases run faster we tried to set the expireMessagesPeriod for all topics to 1s.
By this, a message should be expired and put in DLQ after 2 seconds, right?
But the topics are still only cleaned from expired messages every 30s, despite the expireMessagesPeriod="1000".
On top of that, I never see the "expiring messages" in the log for topics as we can see below for queues.

So the messages can be sent and received, but they don't are not cleaned up as fast as expected (takes 30s instead of 1s).

It's pretty confusing, so does anyone know what's going on?

Config:
        <destinationPolicy>
            <policyMap>
                <policyEntries>
                    <policyEntry topic=">" expireMessagesPeriod="1000" >
                        <pendingMessageLimitStrategy>
                            <constantPendingMessageLimitStrategy limit="1000"/>
                        </pendingMessageLimitStrategy>
                    </policyEntry>
                </policyEntries>
            </policyMap>
        </destinationPolicy>

Log:
2015-09-25 11:11:29,573 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker
2015-09-25 11:11:34,578 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker
2015-09-25 11:11:34,581 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker
2015-09-25 11:11:34,691 | DEBUG | queue://xxxxx expiring messages .. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2015-09-25 11:11:34,693 | DEBUG | queue://xxxxx expiring messages done. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2015-09-25 11:11:34,805 | DEBUG | queue://ActiveMQ.DLQ expiring messages .. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2015-09-25 11:11:34,806 | DEBUG | ActiveMQ.DLQ toPageIn: 0, Inflight: 0, pagedInMessages.size 11, pagedInPendingDispatch.size 11, enqueueCount: 0, dequeueCount: 0, memUsage:18909 | org.apache.activemq.broker.region.Queue | ActiveMQ
BrokerService[localhost] Task-2


Software:
ActiveMQ Version: 5.10
JVM Version: 1.7
Application server: spring + Jboss 6


Regards