rabbitmq

0熱

2答えて

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

0熱

1答えて

kubernetes pod for celery

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

0熱

1答えて

アプリケーションの他のレイヤーからSTOMPメッセージを送信する

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

0熱

2答えて

同じCamel RouteBuilderの設定方法で2つのRabbitMQ接続を設定する方法

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

0熱

1答えて

RabbitMQ別のリスナータイプ別

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

0熱

2答えて

Celery and Rabbit MQ Django

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

0熱

1答えて

メソッドを使用してすべてのメッセージを取得する方法は、lib amqp.nodeで消費されますか？

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