<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>

                企業??AI智能體構建引擎,智能編排和調試,一鍵部署,支持知識庫和私有化部署方案 廣告
                ###32.2.3 接收消息 當Rabbit設施出現時,所有bean都可以注解`@RabbitListener`來創建一個監聽器端點。如果沒有定義`RabbitListenerContainerFactory`,Spring Boot將自動配置一個默認的。如果定義`MessageConverter` beans,它將自動關聯到默認的factory。 下面的組件創建一個`someQueue`隊列上的監聽器端點: ```java @Component public class MyBean { @RabbitListener(queues = "someQueue") public void processMessage(String content) { // ... } } ``` **注** 具體參考[@EnableRabbit](http://docs.spring.io/spring-amqp/docs/current/api/org/springframework/amqp/rabbit/annotation/EnableRabbit.html)。 如果需要創建多個`RabbitListenerContainerFactory`實例,或想覆蓋默認實例,你可以使用Spring Boot提供的`SimpleRabbitListenerContainerFactoryConfigurer`,通過它可以使用跟自動配置實例相同的配置初始化`SimpleRabbitListenerContainerFactory`。 例如,下面使用一個特殊的`MessageConverter`創建了另一個factory: ```java @Configuration static class RabbitConfiguration { @Bean public SimpleRabbitListenerContainerFactory myFactory( SimpleRabbitListenerContainerFactoryConfigurer configurer) { SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); configurer.configure(factory, connectionFactory); factory.setMessageConverter(myMessageConverter()); return factory; } } ``` 然后,你可以像下面那樣在所有`@RabbitListener`注解方法中使用: ```java @Component public class MyBean { @RabbitListener(queues = "someQueue", containerFactory="myFactory") public void processMessage(String content) { // ... } } ``` 你可以啟動重試處理那些監聽器拋出異常的情況,當重試次數達到限制時,該消息將被拒絕,要不被丟棄,要不路由到一個dead-letter交換器,如果broker這樣配置的話,默認禁用重試。 **重要** 如果沒啟用重試,且監聽器拋出異常,則Rabbit會不定期進行重試。你可以采用兩種方式修改該行為:設置`defaultRequeueRejected`屬性為`false`,這樣就不會重試;或拋出一個`AmqpRejectAndDontRequeueException`異常表示該消息應該被拒絕,這是開啟重試,且達到最大重試次數時使用的策略。
                  <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>

                              哎呀哎呀视频在线观看