问题:
解决:
@Argument x-single-active-consumer
Java
1 2 3 4 |
<span id="LC346" class="line" lang="java"> <span class="nd">@RabbitListener</span><span class="o">(</span><span class="n">bindings</span> <span class="o">=</span> <span class="nd">@QueueBinding</span><span class="o">(</span></span> <span id="LC347" class="line" lang="java"> <span class="n">key</span> <span class="o">=</span> <span class="o">{</span><span class="s">"#"</span><span class="o">},</span></span> <span id="LC348" class="line" lang="java"> <span class="n">value</span> <span class="o">=</span> <span class="nd">@Queue</span><span class="o">(</span><span class="n">value</span> <span class="o">=</span> <span class="no">EXCHANGE_DAPEIGOU_FAVORITE_INC</span><span class="o">,</span> <span class="n">durable</span> <span class="o">=</span> <span class="s">"true"</span><span class="o">,</span> <span class="n"><span class="idiff left">arguments</span></span> <span class="o"><span class="idiff">=</span></span> <span class="o"><span class="idiff">{</span></span><span class="nd"><span class="idiff">@Argument</span></span><span class="o"><span class="idiff">(</span></span><span class="n"><span class="idiff">name</span></span> <span class="o"><span class="idiff">=</span></span> <span class="s"><span class="idiff">"x-single-active-consumer"</span></span><span class="o"><span class="idiff">,</span></span> <span class="n"><span class="idiff">value</span></span> <span class="o"><span class="idiff">=</span></span> <span class="s"><span class="idiff">"true"</span></span><span class="o"><span class="idiff">,</span></span> <span class="n"><span class="idiff">type</span></span> <span class="o"><span class="idiff">=</span></span> <span class="s"><span class="idiff">"java.lang.Boolean"</span></span><span class="o"><span class="idiff">)},</span></span> <span class="n">ignoreDeclarationExceptions</span> <span class="o">=</span> <span class="s">"true"</span><span class="o">),</span></span> <span id="LC349" class="line" lang="java"> <span class="n">exchange</span> <span class="o">=</span> <span class="nd">@Exchange</span><span class="o">(</span><span class="n">value</span> <span class="o">=</span> <span class="no">QUEUE_DAPEIGOU_VIEWAD</span><span class="o">,</span> <span class="n">type</span> <span class="o">=</span> <span class="nc">ExchangeTypes</span><span class="o">.</span><span class="na">FANOUT</span><span class="o">,</span> <span class="n">ignoreDeclarationExceptions</span> <span class="o">=</span> <span class="s">"true"</span><span class="o">))</span></span> |
参考: