問題タブ [cloudamqp]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Java RabbitMQ 接続は既に閉じられています
メッセージを外部の rabbitmq にプッシュする必要があります。私のJava構成はプッシュするキューを正常に宣言していますが、プッシュしようとするたびに次の例外があります:
豆:
送信メッセージ サービス クラス:
ちなみに、rabbitmq をローカルで起動すると問題なく動作します。この問題は、コンテナ化された rabbitmq または外部の cloudamqp を使用すると発生します
もう一度、アプリを実行すると、RabbitMQ ダッシュボードに新しいキューが表示されますが (宣言されています)、メッセージをプッシュしようとすると例外が発生します。
node.js - amqplib sendToQueue() が RabbitMQ にメッセージを送信していません
の Promise API を中心に Typescript パッケージを構築してamqplib
、2 つの RabbitMQ キュー間でメッセージを簡単に送信できるようにしています。
これは、RabbitMQ へのメッセージの送信を担当するパッケージのクラス内のメソッドです。CloudAMQP からメッセージを見ることができないため、実際にはメッセージを送信していません。
これは、ここで使用されている接続とチャネルを作成するために作成したクラスです。
}
CloudAMQP のダッシュボードから接続を確認できるため、接続ファクトリは正常に動作しているようです。また、作成された (コードでアサートされた) キューもダッシュボードから確認できます。ただし、amqplib から CloudAMQP にメッセージを送信することができません。
パッケージを呼び出すために使用している(非同期)コードは次のとおりです。
何が間違っているようですか?