rabbitmq

2熱

3答えて

RabbitMQの使用に必要なものは次のとおりです。プロデューサはメッセージを生成し、受信者はメッセージを受信します。メッセージは最初にキューに接続された後に公開されます。消費者は公開されたすべてのメッセージを消費したいからです。複数のコンシューマが同じキューに接続されている場合、コンシューマはすべてのメッセージを受信しません（また、hereを参照）。したがって、消費者はの '排他的な'キューを

2熱

4答えて

RabbitMQコンシューマはメッセージの受信を停止します

私はRabbitMQに深刻な問題があります。一定量のメッセージが受信された後、消費者は単にメッセージの受信を停止する。彼らはまだ接続されていますが、もはやメッセージを受信していません。私はこの問題について他の投稿を見つけましたが、答えはありません。ここに私が使用している接続ラッパーがあります：http://pastebin.com/XVY3HNGqです。私はpythonの非同期のamqp

1熱

1答えて

設定配信モード（RabbitMQの）

The docsは言う： public bool AMQPExchange::publish (string $message , string $routing_key [, int $params = 0 [, array $attributes ]]) だから私はこの $this->exchange->publish(serialize($queue_message), $routing

20熱

5答えて

Celeryで作成された一時キュー

私はRabbitMQでCeleryを使用しています。最近、多数の一時的なキューが作成されていることがわかりました。タスクが失敗したとき（つまりタスクが例外を発生させるとき）、ランダムな名前の一時的なキュー（c76861943b0a4f3aaa6a99a6db06952cなど）が形成され、キューが残っていることを実験したところ、次のようにrabbitmqadminに見られるような一時的なキューの

0熱

1答えて

どのタスクがどのキューに入ったのかを確認する

CeleryでRabbitMQを使用していて、タスクのカスタムルーティング設定をいくつか設定しました。特定の種類のタスクが1つのキューに移動し、他のすべてのタスクが別のキューに移動します。今私はそれが動作しているかどうかを確認したい。このため、どのタスクがどのキューに入ったのかを調べたいと思います。残念ながら、私はこれに私を助けることができる何かを見つけませんでした。 celeryevモニタは、

0熱

1答えて

Ruby AMQPクライアントはメッセージの待機を効率的にブロックしますか？

あなたがキューイングサービスのRubyクライアントであるとします。 RabbitMQ。アクティブなポーリングやリソースを消費しないように、メッセージの実装はどのように実装されていますか？これは質問Ruby blocking on a valueから直接得られます - もしAMQPクライアントが効率的にそれを行うことができれば、Memcachedの読み込みと似たようなことをすることができます...そ

3熱

1答えて

リリースを開始できませんか？

私は、次のアプリケーションを実行するためにbonafideリリースを作成すると思っていました。残念ながら、契約の中断があるようです。私は、このガイドを使用して、最初からプロジェクト作ってみましたまず：そう念のため、 http://alancastro.org/2010/05/01/erlang-application-management-with-rebar.html あいまいなエラーで失敗し

1熱

1答えて

Amazon EC2 Instance＆LocallyのRabbitMQ？

Amazon EC2 instanceにRabbitMQサーバーを設定して、オフィスのマシンをこのRabbitMQサーバーに接続してメッセージを送受信することはできますか？ RabbitMQ EC2 instanceに送受信される帯域幅/メッセージについては、Amazonが請求されますか？

12熱

1答えて

Django/Celeryとの相互運用Javaから

私達の会社には、PythonベースのWebサイトとDjango/CeleryとRabbitMQを介して通信するいくつかのPythonベースのワーカーノードがあります。私はCeleryベースの作業者にタスクを提出する必要があるJavaベースのアプリケーションを持っています。私はJavaからRabbitMQにジョブを送ることはできますが、セラーリーベースのワーカーは決して仕事を引き受けません。両方のタ

3熱

3答えて

埋め込み可能なキュー？

私はアクションを収集し、リモートサーバーに送信するアプリケーションを持っています。これらのアクションはタイムクリティカルではないので（ログラインと考える）、それらをキューに入れてバッチで送信したいと思います。このように、私はまた、（ハードドライブがクラッシュしない限り）メッセージが失われないようにしたいと考えています。 MSMQはむしろヘビー級で、秘密で奇妙なようです。また、システムコンポーネン