rabbitmq

0熱

1答えて

解決「でルートroute1の作成に失敗しました：>>> [stream.out]に」キャメル

でこれは私が実行したときに、私はキュー public class Sender { public static void main(String[] args) throws Exception { CamelContext camelContext = new DefaultCamelContext(); camelContext.addRoutes(new R

2熱

1答えて

スケーラブルなシステムを構築する方法を理解していない

スケールすることができるシステムを適切に構築する方法に関するガイダンスが必要です。私はあなたが何をしようとしているのかについていくつかの情報を与え、次に私の特定の質問をします。私は訪問者に処理するデータを送信させたいサイトがあります。テキストエリアにデータを入力するか、ファイルにアップロードします。シンプル。データは、POST要求がRESTエンドポイントに行われる前に、クライアント側でいくらか前

0熱

2答えて

rabbitmqでセロリタスクキューが動作しない

セロリタスクはキューなしで正常に実行されますセットアップ。 BROKER_URL = "amqp://user:[email protected]:5672/test" # Celery Data Format CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERYD_TAS

1熱

2答えて

サーバ再起動後のドッカーサービスの開始

私はUbuntu（14）のドッカー（17人）と苦労しています。私はドッカー技術を使用して2台のマシンでrabbitMQを実行する必要があります。 sudo docker service create -d --hostname my-rabbit --name some-rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=pa

0熱

2答えて

プリフェッチ回数を動的に設定する方法RabbitMq

プリフェッチ回数を動的に設定することは可能ですか？ここで私は達成したいと思ったものです。私はキューの加入者であるサービスを持っています。私は、プロセッサの使用量、RAMなどのサービスリソースを監視しているメカニズムを持っています。このメカニズムは、このリソースが多く使用されるときにサービスに通知します。だからこの通知が来たら、私はキューからのメッセージの取得をやめたい。それはキューから退会すること

1熱

1答えて

新規インストール時にRabbitMQ UIプラグインをインストールできない

Windows 7でErlangとRabbitMQを完全にインストールする際にRabbitMQ Managementプラグインをインストールしようとしています。私はRabbit MQをインストールしました。 Windowsサービスが動作していることを確認できます。管理プラグインをインストールしようとすると、私はこのエラーを取得： C:\Program Files\RabbitMQ Server\r

1熱

2答えて

RabbitMQとPHPはどのようにタスクをキューに戻しますか？

処理結果が私に合わない場合は、どのようにメッセージをキューに戻すことができますか？メッセージの確認についての情報しか見つけられませんでしたが、私には合わないと思います。処理の結果、RETRYメッセージがキューに追加されて戻ってくる場合は、その必要があります。そして、この労働者か別の人が再びそれをピックアップし、それを処理しようとします。例えば：解決策は、私が思ったより簡単であることが判明し <?

0熱

1答えて

ウサギのMQのフォールトトレランス

私はウサギのMQを使用しているプロジェクトを持っているメッセージブローカーが、私は以下の懸念を持って、同じでお手伝いをしてください。ウサギのMQがダウンした場合、キューに入れられたメッセージを取得する方法はありますか。ウサギMQの設定はありますか？私たちは同じことをjavaスレッドとコレクションの組み合わせで実装できますが、これはrabbit MQの代替として使用できますか？はいの場合は例を参

0熱

1答えて

メッセージプロデューサがコンシューマによって終了した作業の確認を受け取るまで待ちます。

Rubyの "bunny" RabbitMQクライアントを使用して、私のプロデューサー（Rubyコード）が消費者（スニーカー "gemを使用するワーカー）私はプロデューサーが自分のメッセージを受け取り、それにいくつかの作業をしたという確認をプロデイサが受け取るまで、私のプロデューサーにRubyコードの別の行を実行させないようにしたい。私の消費者では、スニーカーのack!メソッドを呼び出してメッセ

1熱

1答えて

ウサギの消費者は、channel.basic.ackの後に消費を停止します

私はpython 3とamqpstormパッケージを使用します。私は、コードのこの部分（省略）オープンRabbitMQの接続での作業を持っている： ichannel = connection.channel(rpc_timeout = 5) ichannel.basic.qos(10000) ichannel.queue.bind(...) ichannel.basic.consume(se