rabbitmq

    0

    2答えて

    メッセージングバックエンドとしてRabbitMQを使用して、「longjobs」というキューからタスクを処理するようにCelery 4.1ワーカーを設定しました。 My Celeryの設定と作業者は、Django 1.11プロジェクトによって管理されます。 何もエラーは発生しませんが、私のDjangoアプリケーションから起動されたタスクは私のワーカーによって決して拾われません。 マイcelery.

    0

    1答えて

    セロリ、ラビットMQ、フラワーで分散タスクの仕組みを実行する必要があります。 通常、私のケースでは3つのポッドを作るサービスごとに別々のポッドを作成します。私の質問は3ポッドを作る理由です。 3つの容器で1つのポッドを作成できます。サービスは緊密に結合されており、実用的なソリューションを得るためにはすべて実行している必要があります。 3つの容器に1つのポッドの代わりに3つのサービスに3つのポッドを

    1

    1答えて

    rabbotを使用してRabbitMQに接続するノードサーバーがあります。これは正常に動作しています。メッセージを発行したり、メッセージを消費したりすることができます。 私は、RabbitMQサーバーに具体的に実行されているバージョンを問い合わせることができます。 私は、バージョンを尋ねるメッセージを公開し、回答キューを介して回答を得ることができることを期待していました。または、私はHTTP経由で

    0

    1答えて

    RabbitMQブローカーを使用してクラスタ化されたTomcat環境でSpring Websocketを使用してアプリケーションを構築しています。私は聞くエンドポイントを登録する必要があるAPIモジュールを持っています。私は、通常の例に続き、この設定を思い付いた:これは動作しますが、そのためできない他の層を残して、すべてのAPIモジュールにバンドルされているのWebSocketとリレー設定を表示さ

    0

    2答えて

    私は、ウサギの待ち行列、処理、および投稿メッセージを別のウサギ待ち行列から聞きたい。私は春と一緒に働いていない。メッセージはこの構成で複製されます。 これは短いコードです:私はこれも試してみました context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception

    0

    1答えて

    私は、Rabbit MQへのメッセージを表すPOJOを持っています。メッセージのタイプに責任がある整数(ように、それはだかどうかupdate、remove、addとは)あり: public class Message { private String field1; private String field2; private Integer type;

    0

    2答えて

    私は、コマンド: pip install celeryとsudo apt-get install rabbitmqでCeleryとRabbitMQをインストールしました。 セロリは機能しません。私はこのエラーを取得: Traceback (most recent call last): File "/home/morilon/dj/shop/lib/python3.5/site- pa

    0

    1答えて

    上のバーチャルホストでノーキュー私はRabbitMQのは、この構成のクラスで構成された春のブートアプリケーションを起動しようとしている: @Configuration public class RabbitConfig implements RabbitListenerConfigurer { public static final String AMQP_EXCHANGE_NAME

    0

    1答えて

    私は多くのRabbitMQブローカとシングルセロリアプリケーションを持っています。 すべてのブローカーからのすべてのメッセージをこの1つのアプリケーションにルーティングしたいと考えています。これを行う最も簡単な方法は何ですか? 私はそれがRabbitMQブローカー間の連合を作成することによって行うことができることを知っています、私はそれを行う別の方法があることを知りたいと思います。

    0

    1答えて

    挨拶する人。 node.jsで非同期で手助けできますか? 私がここにありRabbitMQとの仕事のために使用amqplib moduleだとRabbitMQのからのメッセージを与えるを消費方法、彼はを開始し、この後、約その方法最初のリターンの約束:この 問題約束は始まる、RabbitMQからデータを得るためにコールバックをコールし、すべてのメッセージが私のノードjsアプリに送信される時を捕まえる方