rabbitmq

    0

    1答えて

    RabbitMQ rpcを設定しようとしています。 1つのキューにリッスンしたい場合は、メッセージを受信したときにreply_toヘッダーで複数のメッセージで指定されている匿名キューに返信します。 私は以下のトールタスクがキューを作成し、EMを使用してい:イテレータはバックreplyt_toがキールーティングで指定されたキューへのメッセージの数を送信するために: desc "start_consu

    20

    6答えて

    Ubuntu用のRabbitMQをインストールする簡単な方法はありますか?その後、apt-getでインストール deb http://www.rabbitmq.com/debian/ testing main :/etc/apt/sources.listに次の行を追加します。 :私は次のことをやった $ sudo apt-get install rabbitmq-server をしかし、私

    1

    1答えて

    私はプロジェクトにAMQPを使用しようとしており、RabbitMQを使いたいと思っています。私の問題は、プラットフォームの1つがAIX 6であり、プラットフォーム用のインストール可能なバイナリが見つからないということです。さらに悪いことに、AIX用のerlangのポートがないように見えます。 誰でも私に、AIX 6のerlangへのポインタを与えることができますか、あまりにも痛みを伴うことなくコン

    2

    1答えて

    プロデューサには、twitterストリームから読み込み、メッセージブローカとしてrabbitmqを使用してキューにタスクを配置します。 ジョブは、通常、実行に周りに3-5秒かかり、それが行われたときに仕事の終わりに私は、ユーザーに通知します。しかし、私はまた、仕事をしてから10分/ 30分/ 60分後に、ユーザーにもっとメッセージを送ることで思い出させたいと思います。 私はこれらの追加のメッセージ

    2

    2答えて

    異なるWebサービスととMQの間で決定する方法 、私は最近、MQSに探し始めていると私はいくつかの非常に基本的な質問を持っていましたか? はMQSは文字列のみメッセージを送信することができますまたはJavaが同様 は、クライアントとサーバが存在する場所の面で制約があるオブジェクトとそれが動作することができますか?それとも

    0

    1答えて

    django-celery(バックエンドとしてrabbitmqを使用)でいくつかのタスクを実行しているので、タスクは時間がかかり、CPUが集中します。 私は2つのワーカーEc2インスタンスを持っています(1つは小さく、もう1つは高いCPUコアです)。 Iveは1つの並行タスクを実行するように小さなインスタンスを設定し、メディアは4を実行します。これは私にとってはうまく機能します。しかし、セミモニタ

    1

    1答えて

    私はpika.SelectConnectionを使ってRabbitMqサーバと通信するいくつかのスクリプトを持っています。 スクリプトが動作しているときに、サーバがダウンした場合に、それらのスクリプトが自動的にrmqサーバに再接続しようとしていますか?

    8

    1答えて

    のインスタンスを1つだけ実行します。このプロセスは通常5分を超えて実行されるべきではありませんが、2番目のインスタンスが実行された場合、2番目のインスタンスが起動しないようにしたいと思います。 previous recommendationあたり、私はDjango Celeryを使用してこの長期実行タスクをスケジュールしています。 私は5分の期間を持っている場合、私はタスクの別のインスタンスがすで

    2

    1答えて

    タスクを実行してdjangoによって配布されたメッセージを返す複数のマシンを使用できますか?私はセロリ/ rabbitmqを見て、私はリモートコンピュータ上でセロリの労働者を設定することができますか分かりません。誰も私をここまで導くことができますか? これが可能ではない、または非常に難しい場合は、問題の代替ソリューションはありますか?

    0

    1答えて

    RabbitMQは、デフォルトでメッセージ「ディスクノード」を格納します。ディスクノードに直接メッセージを格納するのではなく、RAMノードにメッセージをルーティングするオプションはありますか? 少し緊急です。私に提案してください。 よろしく、 Rambabu