<html>
<head>
<style><!--
.hmmessage P
{
margin:0px;
padding:0px
}
body.hmmessage
{
font-size: 10pt;
font-family:Tahoma
}
--></style>
</head>
<body class='hmmessage'><div dir='ltr'>
Hello Cameron:<br>
<br>
To resolve any confusion, let me make a table to clarify. I DO have "x-ha-policy" set to "all"<br>
<br>
&nbsp; Steps &nbsp;&nbsp; |&nbsp;&nbsp; vm1 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; | &nbsp; &nbsp;&nbsp; &nbsp; vm2<br>
&nbsp; ------------------------------------------------------------------------------<br>
&nbsp; 1.&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp; started (10 msg, disk, master) &nbsp; |&nbsp; started (10 msg, disk)<br>
&nbsp; 2.&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp; stop&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp;&nbsp; |&nbsp; started (10 msg, disk, became master)<br>
&nbsp; 3.&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp; started (10 msg, disk, slave)&nbsp;&nbsp; &nbsp;&nbsp; |&nbsp; started (10 msg, disk, master)<br>
&nbsp; 4.&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp; started (0 msg, disk, master)&nbsp;&nbsp;&nbsp;&nbsp; | stop<br>
<br>
Noticed that in my step 4, when I stop my VM2, the message in VM1 
immediately disappear. You are right, each step has interval of about 10
 seconds, I didn't wait very long to stop the new master. You mentioned 
that I have to I have to wait until the queues are synchronized. How 
long is that waiting? Is there a command that I could find out if they 
finished the synchronization? Like rabbitmqctl command or anything? Or 
any way to force synchronize right now. I am only testing 10 messages, 
it shouldn't take that long.<br>
<br>
Thanks for your help.<br>
<br>
Jeffrey.<br><br><div>&gt; From: cameron.davison@gmail.com<br>&gt; Date: Mon, 21 Nov 2011 23:46:24 -0600<br>&gt; Subject: Re: [rabbitmq-discuss] active/active message persistence problem<br>&gt; To: cpthk@hotmail.com<br>&gt; CC: rabbitmq-discuss@lists.rabbitmq.com<br>&gt; <br>&gt; What order are you restarting the nodes? Any rabbitmq server that<br>&gt; connects to a cluster will start its queue fresh and begin replicating<br>&gt; from the master. You should wait and make sure that all the queues are<br>&gt; synchronized before you shut down the master, or new master. Old<br>&gt; messages are not read from nodes that connect to the cluster because<br>&gt; the assumption is that the queue will go to 0 soon and then the old<br>&gt; messages will not matter so only the new messages will be important.<br>&gt; Also, you should make sure that the "x-ha-policy" is set to "all" or<br>&gt; to the "nodes" that you would like the queue to be mirrored to.<br>&gt; <br>&gt; Cameron<br>&gt; <br>&gt; On Mon, Nov 21, 2011 at 7:14 PM, Jeffrey Chen &lt;cpthk@hotmail.com&gt; wrote:<br>&gt; &gt; Hi RabbitMQ community:<br>&gt; &gt;<br>&gt; &gt; I am encounter this problem about message persistence. Here is my case, I<br>&gt; &gt; have 2 server nodes with active/active setup, both are persisted to DISK.<br>&gt; &gt; The queue declarations are defined as durable.<br>&gt; &gt; This is what I got when doing:<br>&gt; &gt;<br>&gt; &gt; # rabbitmqctl cluster_status<br>&gt; &gt; Cluster status of node 'rabbit@aaron-vm177' ...<br>&gt; &gt; [{nodes,[{disc,['rabbit@vm1','rabbit@vm2']}]},<br>&gt; &gt; &nbsp;{running_nodes,['rabbit@vm1','rabbit@vm2']}]<br>&gt; &gt; ...done.<br>&gt; &gt;<br>&gt; &gt; # rabbitmqctl list_queues<br>&gt; &gt; Listing queues ...<br>&gt; &gt; test &nbsp;&nbsp; 10<br>&gt; &gt; ...done.<br>&gt; &gt;<br>&gt; &gt;<br>&gt; &gt; My vm1 is currently master node. When I stop RabbitMQ service in vm1, and<br>&gt; &gt; start it back up. I check my messages in the queue, the messages are still<br>&gt; &gt; there. This time when I stop RabbitMQ service in vm2. The messages will be<br>&gt; &gt; gone. It seems like when I restart both server nodes, the data will be lost.<br>&gt; &gt; Does anyone know the reason? Is there any way to work around this?<br>&gt; &gt;<br>&gt; &gt; My goal is that any server nodes down, and when I bring it back up, no data<br>&gt; &gt; will be lost.<br>&gt; &gt;<br>&gt; &gt; Jeffrey.<br>&gt; &gt;<br>&gt; &gt; _______________________________________________<br>&gt; &gt; rabbitmq-discuss mailing list<br>&gt; &gt; rabbitmq-discuss@lists.rabbitmq.com<br>&gt; &gt; https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<br>&gt; &gt;<br>&gt; &gt;<br></div>                                               </div></body>
</html>