Hello Lu,
This sounds like a bug to me. Can you please create a JUnit test and raise a bug report? Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Sep 11, 2013, at 11:01 PM, rushalias wrote: > Here is my setup > > I have a master/slave (apache-activemq-5.8.0) configuration using MySql > database as a shared storage. > > Next a client connects to the current master broker via > failover:(tcp://host1:61616,tcp://int-host2:61616)?randomize=false and posts > a message with a delayed delivery to a queue. > > Delay is set via this > > message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay); > > Under normal operation delayed messages are delivered to consumers after the > correct amount of delay. > > BUT > If the current master broker, where the client connected to and posted > delayed messages, goes down and a slave is selected master those delayed > messages will never be delivered. I have looked at the code and it seems > delayed messages are stored locally using classes from > org.apache.activemq.store.kahadb.scheduler package which is dealing with > local disk only. > > Is this expected behavior? > > Thanks all, > -Lu > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Delayed-messages-not-delivered-when-master-goes-down-tp4671431.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
