To Give &nbsp;a few code examples, (I have omitted the non-relevant parts):<div><br></div><div>try {</div><div>







<p class="p1"><font face="'courier new', monospace"><span class="s1">this</span>.<span class="s2">consumer</span>.nextDelivery();</font></p><p class="p1"><span style="font-family: 'courier new', monospace; ">} </span><span class="s1" style="font-family: 'courier new', monospace; ">catch</span><span style="font-family: 'courier new', monospace; "> (ShutdownSignalException e) {</span></p>
<p class="p2"><font face="'courier new', monospace"><span class="s3"><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span></span><span class="s2">&nbsp; log</span><span class="s3">.error(</span>"ShutdownSignalException"<span class="s3">, e);</span></font></p>
<p class="p1"><font face="'courier new', monospace"><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="s1">&nbsp; if</span> (<span class="s1">this</span>.<span class="s2">channel</span>.isOpen()) {<br></font><span class="s1" style="font-family: 'courier new', monospace; ">&nbsp; &nbsp; try</span><span style="font-family: 'courier new', monospace; "> {<br></span><span class="s1" style="font-family: 'courier new', monospace; ">&nbsp; &nbsp; &nbsp; this</span><span style="font-family: 'courier new', monospace; ">.</span><span class="s2" style="font-family: 'courier new', monospace; ">channel</span><span style="font-family: 'courier new', monospace; ">.close();<br></span><span style="font-family: 'courier new', monospace; ">&nbsp; &nbsp; } </span><span class="s1" style="font-family: 'courier new', monospace; ">catch</span><span style="font-family: 'courier new', monospace; "> (AlreadyClosedException e1) {}<br></span><span style="font-family: 'courier new', monospace; ">&nbsp; }</span></p>
<p class="p1"><font face="'courier new', monospace"><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="Apple-tab-span"></span><span class="s1">&nbsp; if</span> (<span class="s1">this</span>.<span class="s2">connection</span>.isOpen()) {</font></p>
<p class="p1"><span class="s1" style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp; &nbsp; try</span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp;{<br></span><span class="s1" style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp; &nbsp; &nbsp; this</span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">.</span><span class="s2" style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">connection</span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">.close();<br></span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp; &nbsp; }&nbsp;</span><span class="s1" style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">catch</span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp;(AlreadyClosedException e1) {}<br></span><span style="border-style: initial; border-color: initial; font-family: 'courier new', monospace; ">&nbsp; }</span><font face="'courier new', monospace"><br></font></p>
<p class="p1">







</p><p class="p1"><font face="'courier new', monospace"><span class="s1">&nbsp; this</span>.<span class="s2">connection</span> = <span class="s2">factory</span>.newConnection();<br>







</font></p><p class="p1"><font face="'courier new', monospace"><span class="s1">&nbsp; this</span>.<span class="s2">channel</span>.basicRecover();</font></p><p class="p1"><font face="'courier new', monospace"><br></font></p><p class="p1"><font face="'courier new', monospace"><br></font></p><p class="p1"><font face="'courier new', monospace">I've got some logic in there to back off during connection refused, but its when the server comes back online that I can't get rid of the ShutDownSignalExceptions.</font></p><p></p><p></p></div>