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

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

如何使用 spring 集成 java DSL 將消息發(fā)送到 rabbitmq 隊(duì)列

如何使用 spring 集成 java DSL 將消息發(fā)送到 rabbitmq 隊(duì)列

DIEA 2023-06-21 13:29:10
我編寫(xiě)了簡(jiǎn)單的示例來(lái)從控制臺(tái)讀取文本并將其發(fā)送到rabbitMq服務(wù)器:@Configuration@EnableIntegration@IntegrationComponentScanpublic class Config {    @Autowired    private AmqpTemplate amqpTemplate;    @Bean    public IntegrationFlow fromConsoleToRabbitFlow() {        return IntegrationFlows.from(consoleSource(), c -> c.id("consoleInput")                .poller(Pollers.fixedRate(1000))                .autoStartup(true)        ).channel("consoleOutputChannel")                .handle(Amqp.outboundAdapter(amqpTemplate).routingKey("my_spring_integration_queue"))                .get();    }    public MessageSource<String> consoleSource() {        return CharacterStreamReadingMessageSource.stdin();    }}my_spring_integration_queue它看起來(lái)幾乎可以工作的解決方案,但我在rabbitmq管理控制臺(tái)中找不到:但我在其他選項(xiàng)卡上找不到與“my_spring_integration_queue”相關(guān)的任何內(nèi)容。我在哪里可以找到它?我希望應(yīng)用程序會(huì)創(chuàng)建隊(duì)列(如果不存在)。我無(wú)法找到發(fā)送到隊(duì)列的方法,所以我使用了.routingKey方法。我也嘗試過(guò).exchangeName方法,但它導(dǎo)致:32019-08-27 13:26:15.972 ERROR 16372 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'my_spring_integration_queue' in vhost '/', class-id=60, method-id=40)聚苯乙烯隊(duì)列選項(xiàng)卡如下所示:
查看完整描述

1 回答

?
阿晨1998

TA貢獻(xiàn)2037條經(jīng)驗(yàn) 獲得超6個(gè)贊

您需要手動(dòng)添加隊(duì)列或使用 aRabbitAdmin?@Bean自動(dòng)為您聲明它 - 管理員將找到所有類(lèi)型的 beansQueue并聲明它們。

如果你使用的是 Spring Boot,它會(huì)自動(dòng)為你配置一個(gè)管理 bean,所以你只需要Queue?@Bean.

查看完整回答
反對(duì) 回復(fù) 2023-06-21
  • 1 回答
  • 0 關(guān)注
  • 170 瀏覽
慕課專(zhuān)欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號(hào)

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