Please change line 84 of PersistentMessageListener from:
Topic topic = session.createTopic("BOO.X?consumer.retroactive=false");
to:
Topic topic = session.createTopic(topicName +
"?consumer.retroactive=false");This was the hard coded alternate topic test I mentioned, to see the problem you'll need to change back to the dynamic topic as above. -- View this message in context: http://www.nabble.com/Re%3A-Recovery-Policies-should-apply-between-broker-restart-tf1996384.html#a5566290 Sent from the ActiveMQ - Dev forum at Nabble.com.
