<div><div>Hello,</div><div><br></div><div>I have a 2 node (both disk) cluster setup. In an attempt to simulate a node failure I am killing the erlang process hosting rabbit on the master for a durable queue. I would expect to get a HandleBasicCancel as defined in the documentation, however I am only getting an OnCancel. Is this expected? Should I be simulating a node failure in another way? I tried setting the client capabilities but it seems the C# client sends true for consumer_cancel_notify no matter what I specify. I validate this via the management website for the connection and see:</div><div><br></div><div>capabilities<span class="Apple-tab-span" style="white-space:pre">        </span></div><div>publisher_confirms:<span class="Apple-tab-span" style="white-space:pre">        </span>true</div><div>exchange_exchange_bindings:<span class="Apple-tab-span" style="white-space:pre">        </span>true</div><div>consumer_cancel_notify:<span class="Apple-tab-span" style="white-space:pre">        </span>true</div><div>basic.nack:<span class="Apple-tab-span" style="white-space:pre">        </span>true</div><div><br></div><div>I create the queue with the following code:</div><div><br></div><div>ConnectionFactory factory = new ConnectionFactory(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;</div><div>factory.HostName = "localhost"; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</div><div><br></div><div>this.connection = factory.CreateConnection(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</div><div>this.channel = this.connection.CreateModel(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</div><div>this.queueConsumer = new FabricNotificationQueueConsumer(this.region, this.groupName, this.serializer,</div><div>&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; &nbsp; &nbsp; &nbsp; &nbsp;this.cache);</div><div><br></div><div>Dictionary&lt;string, object&gt; queueArgs = new Dictionary&lt;string, object&gt;();</div><div>queueArgs.Add("x-ha-policy", "all");</div><div><br></div><div>this.channel.QueueDeclare(QueueName, true, false, false, queueArgs);</div><div>this.channel.QueueBind(QueueName, exchange, string.Format("{0}.{1}.*", this.region, this.groupName));</div><div>this.channel.BasicConsume(QueueName, true, this.queueConsumer);</div><div><br></div><div>Thanks for your help,</div><div>Mike</div><div><br></div><div><br></div></div>