rabbitmq

    0

    1答えて

    私は最新のバージョンog php-amqpをインストールしましたが、私は方法channel()を使用しているようです。これは、コード <?php ini_set('display_errors', 1); ini_set('display_startup_errors', 1); error_reporting(E_ALL); require_once __DIR__.'/vendor

    0

    1答えて

    私のrabbitmqサーバーを起動しようとしましたが、このエラーが発生します。私はhow to install itのすべての指示に従った。 rabbitmq-serverファイルは/usr/local/sbinの中にあります。だから、ディレクトリをsbinに変更し、私の端末にrabbitmq-serverと書きますが、エラー-bash: rabbitmq-server: command not

    0

    1答えて

    rabbitmq-serverファイルは/usr/local/sbinの中にあります。だから私はディレクトリをsbinに変更し、私の端末にrabbitmq-serverを書き込むと、端末にこれらの行が正常に起動して表示されます。 しかし最後の行にはまってしまいます。

    0

    1答えて

    を取得します.1つはクラウドフロント(cf)用で、もう1つはエルボ用です.Jsonにはいくつかの値が割り当てられています私は私のELBスクリプトを実行し、要求queue.whenと呼ばれるキュー(RabbitMQの)、内側にそれは私が私のCFのスクリプトを実行すると、それはFILE_TYPE = CFでのみMSGを取得する必要がありますFILE_TYPE = ELB {'file_type':'e

    0

    1答えて

    私たちはメッセージブローカーとしてRabbitMQを使用しています。 Producer1はAMQPを使用して接続し、Producer2はSTOMPプロトコルを使用して接続し、Consumer1はAMQPを使用して接続し、Consumer2(javascriptを使用)はWebSocket経由でSTOMPを使用して接続します。 (Producer1とconsumer1はスプリングクラウドストリームを

    0

    0答えて

    私たちは、サーバー外部のイベントによって生成されたRabbitMQ(または多分Redis)メッセージを受け取ります。 私たちのDjangoアプリにそのようなイベントで通知されるようにするには(そして私たちのコードを実行してください)? セロリでできますか?

    0

    1答えて

    nginxでアクションを実行したいと思います。 同様: MQ->addQueue("work","to do"); //This queue performs to nginx listener or connection server { listen 5672; // or connect proxy_pass http://stream_workers } //T

    0

    1答えて

    私はthisチュートリアルに従っています。そこで、RabbitMQのIPアドレスをセロリの設定にする必要があります。 docker-compose.ymlにNGINX、Django + Celery、RabbitMQという3つのコンテナがあります。これらはすべてdocker-compose upで実行されます。しかし、別のコンテナにcelery.pyのRabbitMQ IPアドレスを設定する必要が

    0

    1答えて

    いくつかの異なるサーバーの単一のインスタンスから多数のクライアントにメッセージを送信する必要のある一連のTomcat/Springアプリケーションがあります。各サーバーインスタンスには、独自の交換セットがあります。エクスチェンジはサーバによって宣言され、各クライアントによって生成され、それらのエクスチェンジにバインドされた匿名キューが宣言されます。私は匿名キューを使用しています。なぜなら、あらかじ

    0

    1答えて

    私はRabbitMQのコンシューマとしてナキウサギねじれた接続を使用して、ここに私のコードです: @defer.inlineCallbacks def run(connection): queue_name = 'aaa' channel = yield connection.channel() queue = yield channel.queue_declare