<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                `AmqpTemplate`的`RabbitTemplate`實現支持發布確認和返回。 為了返回消息,必須將模板的`mandatory`屬性設置為`true`,或者對于特定消息,`mandatory-expression`必須求值為`true`。 此功能需要將`CachingConnectionFactory`的`publisherReturns`屬性設置為true。 返回發送到客戶端,是通過調用`setReturnCallback(ReturnCallback callback)`注冊`RabbitTemplate.ReturnCallback`。 回調必須實現此方法: ~~~java void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey); ~~~ 每個`RabbitTemplate`只支持一個`ReturnCallback`。 另請參閱“回復超時”一節。 * * * * * 對于發布確認(也稱為發布應答),模板需要一個將`publisherConfirms`屬性設置為`true`的`CachingConnectionFactory`。 通過調用`setConfirmCallback(ConfirmCallback callback)`注冊`RabbitTemplate.ConfirmCallback`,將確認發送給客戶端。 回調必須實現此方法: ~~~ void confirm(CorrelationData correlationData, boolean ack, String cause); ~~~ `CorrelationData`是客戶端在發送原始消息時提供的對象。 `ack`對于`ack`是真的而對于`nack`是假的。 對于`nack`,如果在生成nack時可用,則原因可能包含nack的原因。 一個例子是向不存在的交換機發送消息。 在這種情況下,代理關閉渠道; 關閉的原因包括在`cause`中。 `cause`在1.4版中添加。 一個`RabbitTemplate`僅支持一個`ConfirmCallback`。 >當rabbit 模板發送操作完成時,通道關閉;這在連接工廠緩存已滿的情況下將阻止接收確認或返回(當緩存中有空間時,通道未物理關閉且返回/確認將正常進行)。當緩存已滿時,框架將關閉延遲最多5秒,以便有時間接收確認/返回。使用確認時,收到最后確認時將關閉頻道。僅使用返回時,通道將保持打開整整5秒。通常建議將連接工廠的channelCacheSize設置為足夠大的值,以便將發布消息的通道返回到緩存而不是關閉。您可以使用RabbitMQ管理插件監控頻道使用情況;如果您看到頻道被快速打開/關閉,您應該考慮增加緩存大小以減少服務器上的開銷。 > >使用默認的交換機是不支持發布的確認和返回的
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看