rabbitmq

0熱

2答えて

永続化されたRabbitMQメッセージを検査する方法はありますか？それらはどこに保管されていますか？

ローカルマシン上でいくつかのテストを行っているだけで、RabbitMQ（deliveryMode = 2）によって公開され、永続化されているメッセージを検査したいと思います。少なくとも、メッセージが実際に保持された時間があること。最初の試みは、管理者の管理のRabbitMQたすべてのオプションとトラフ行ってきました私は何を発見したことは次のようである最も近い：rdq extenstionsと多くの

0熱

1答えて

キューが削除されていることを知るには？

は私がキューを作成： _channel = rmqConnection.CreateModel(); _channel.QueueDeclare("myqueue", false, false, false, null); _channel.BasicAcks += _channel_BasicAcks; _channel.BasicNacks += _cha

1熱

1答えて

RabbitMQ basic_publishは非同期ですか？

私は以下のプロデューサーコードを持っています。メッセージは、いくつかの計算後に得られたdictデータです。私はメッセージをキューに公開したいと思います。その後、というメッセージを他の計算のために空のdictにリセットしました。しかし、消費者は常にキューから空のdictを得ています。私はメッセージが公開される前にリセットされていると感じています（非同期ですか？）。どのように同期させるには？ mes

0熱

1答えて

スケジューラがジョブをキューに入れない

KubernetesでAirflowをテストしようとしています。スケジューラー、ワーカー、キュー、およびWebサーバーはすべて異なる展開であり、私は自分のタスクを実行するためにセルリーエグゼキュータを使用しています。スケジューラがジョブをキューに入れることができないという事実を除いて、すべてがうまくいきます。気象は、Web UIやCLIから手作業で実行すると、うまくタスクを実行できますが、スケジ

0熱

1答えて

なぜ私のrabbitMQクライアントに接続できませんか？

TLSv1.2を使用してサーバーとRabbitMQ接続を作成しようとしていますが、java.net.SocketExceptionがあります。接続のリセットまたはjavax.net.ssl.SSLHandshakeException：致命的な警告を受け取りました：handshake_failure（この例外は変更されているようです無作為に）。私はTLSv1.0を持っていたときに動作しましたが、サ

1熱

1答えて

サーバがダウンした後、Rabbit MQに再接続するには？

私はウサギRPCを使用するスプリングブートアプリケーションを持っています。問題は、アプリケーションが起動すると、Rabbitサーバーがダウンしても、アプリケーションはサーバーに再接続しないということです。また、ウサギサーバーがダウンしている間にアプリが起動すると、失敗し、ウサギが再び上がった後にウサギに再接続しようとしません。ここは、ウサギのサーバーに障害が発生し、再起動した場合にどのように私

0熱

1答えて

RabbitMQ DockerコンテナがAWS EC2インスタンス上で動作しない

Dockerを使用してPHP AMQライブラリで使用されているRabbitMQドッカーコンテナを実行しています。私のラップトップでローカルで実行している場合、すべて正常に動作し、RabbitMQは要求を受け入れることができます。しかし、テストのためにt2.mediumインスタンスにデプロイする場合、RabbitMQコンテナは40-50秒ごとに再起動とクラッシュを続けます。さらに悪いことに、私

0熱

2答えて

RabbitMQとNiFi

私はNiFiを新しくしており、助言を歓迎します。多くの小さなレコードで外部から送信されたデータを取得します。私はこれらのレコードをRabbitMQ経由でNiFiに取り込むことを考えています。私は、それらのレコードを（おそらくレコードのいくつかのインデックスに基づいて）より大きなグループ化に「スプール」または「バッチ」し、あるレコードグループがS3に一定のサイズのしきい値に達すると、 NiFiでこ

0熱

2答えて

OpenSSLからRabbitMQへの接続時に無限に接続がハングアップする - エラーが表示されない

RabbitMQサーバーでSSL接続を設定しました。ウサギのログに探して - 私ははっきりとそのうさぎが5671ポートを監視次を参照してください。残念ながら =INFO REPORT==== 5-Dec-2017::15:27:59 === started SSL Listener on [::]:5671 =INFO REPORT==== 5-Dec-2017::15:27:59 ===

0熱

1答えて

フェデレーションプラグインを使用したIoT用RabbitMQ？

RabbitMQとフェデレーションプラグインについて混乱します。したがって、私はそれを動作させることができないようです。のは、私はそれらすべてがクラウドサーバ（C1）にメッセージを送信したいラズベリーパイS（rpi1、rpi2、rpi3 ... RPIN）の 'n' の数があるとしましょう。インターネットに断続的に接続するので、サーバーに送信する前に、すべてのユーザーがメッセージをローカルに