第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機(jī)立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

RabbitMQ延遲接收

RabbitMQ延遲接收

HUH函數(shù) 2023-03-02 16:38:12
是否有可能以某種方式推遲 spring-amqp 中某個特定隊列的監(jiān)聽消息?在我的用例中,我有一個服務(wù)必須監(jiān)聽兩個 RabbitMQ 隊列上的消息。第一個專用于此服務(wù),第二個用于我服務(wù)的多個實(shí)例(在不同機(jī)器上運(yùn)行)的負(fù)載平衡作業(yè)。我在 statup 上的服務(wù)通過第一個隊列接收配置并自行配置。只有在該配置之后,才允許處理來自第二個隊列的“標(biāo)準(zhǔn)”作業(yè)——而不是之前。我怎樣才能做到這一點(diǎn)?使用 @RabbitListener(queues = {queue1,queue2}) 立即開始收聽。我也看過 rabbitmq_delayed_message_exchange,但這不是我想要的,因?yàn)樗舆t了消息的處理。我不想延遲處理(其他已經(jīng)配置的消費(fèi)者可以處理工作)。感謝您的任何幫助。
查看完整描述

1 回答

?
慕標(biāo)5832272

TA貢獻(xiàn)1966條經(jīng)驗(yàn) 獲得超4個贊

有@RabbitListener一個autoStartup選項(xiàng):


/**

 * Set to true or false, to override the default setting in the container factory.

 * @return true to auto start, false to not auto start.

 * @since 2.0

 */

String autoStartup() default "";

我想你最好有兩個單獨(dú)的@RabbitListeners:一個用于配置隊列,另一個用于非自動啟動。配置準(zhǔn)備就緒后,您需要從中獲取第二個容器的容器RabbitListenerEndpointRegistry.getListenerContainer()并調(diào)用其start(). 你id也可以在那一秒配置@RabbitListener:


/**

 * The unique identifier of the container managing for this endpoint.

 * <p>If none is specified an auto-generated one is provided.

 * @return the {@code id} for the container managing for this endpoint.

 * @see org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry#getListenerContainer(String)

 */

String id() default "";

有關(guān)詳細(xì)信息,請參閱文檔:https://docs.spring.io/spring-amqp/docs/2.1.7.RELEASE/reference/html/#async-annotation-driven


查看完整回答
反對 回復(fù) 2023-03-02
  • 1 回答
  • 0 關(guān)注
  • 165 瀏覽

添加回答

舉報

0/150
提交
取消
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號