activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rushalias <lu.a.tahmaz...@gmail.com>
Subject Delayed messages not delivered when master goes down.
Date Wed, 11 Sep 2013 18:39:07 GMT
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.

Thanks all,
-Lu 




--
View this message in context: http://activemq.2283324.n4.nabble.com/Delayed-messages-not-delivered-when-master-goes-down-tp4671424.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message