message-queue

1熱

1答えて

私が達成しようとしているものは、ユーザーが従業員が処理するバッチ処理を動的に実行できるマルチテナントアプリケーションを構築しています。私たちは、一人のユーザからの単一のバッチを持っている場合は、すべての労働者は、この単一のユーザーからのメッセージ上で動作している別のユーザーがバッチジョブを送信する場合、各ユーザーは、労働者の半分を取得します（最初のユーザーはあるように現在遅い速度で作業していま

1熱

1答えて

ETA/CountdownでTaskQueueを実装する

一般的なタスクキュー（Google GAE TaskQueue、Celeryなど）にはETA/Countdown機能があり、xxx秒後にタスクをキューに入れることができます。私はETA機能を備えたタスクキューを必要とするプロジェクトに取り組んでいます。しかし、私はGoogleのPubsubメッセージングシステムを使用する必要がいくつかの制限があります。 PubsubにはETA機能はありません。私

1熱

1答えて

ブーストを使用して同時プロセス間メッセージキューを構築することはできますか？

私は複数のプロセスを持つアプリケーションを構築しようとしています。これらのプロセスは、同じメッセージキューを介して同時に書き込む必要があります。反対側には、そのキューを読み取るプロセスが1つだけあります。ブーストを使用して可能ですか？あるいは、その相互排除を実装する必要がありますか？サンプルソースコードを見ましたが、私のニーズに合わせて正しく動作していません。私は何かが欠けているかどうか分から

1熱

1答えて

なぜエラー番号S_objLib_OBJ_UNAVAILABLEがありますか？

何らかの理由でキューにデータを送信したいが、errno S_objLib_OBJ_UNAVAILABLE（3997698）が表示され、その理由が分からない。ここに私が持っているものがあります： static MSG_Q_ID bfd_to_alm_data = NULL; // in bfd_queues_create(void) if (!bfd_to_alm_data) { b

2熱

2答えて

RxJSを使用してangularjsモジュール間の通信にMessageBusを実装する

angulajsアプリケーション内でRxJSを使用してpub/subメッセージメッセージキューを作成できますか？私は例として2つのモジュールを持っています： ModuleA ModuleB それらは別々のnpmパッケージとして存在しますが、ModuleCで接続されています。これはメインシェルです。私はModuleDとして依存関係を作成し、モジュール間の緊密な結合を作りたくありません。だから私の考

4熱

2答えて

タイプの1つのコンストラクタでしか機能しない関数

メッセージキュー用のlibを作成しています。キューはDirectまたはTopicのいずれかです。 Directキューには静的バインディングキーがあり、Topicキューには動的バインディングキーを設定できます。 Directキューでのみ機能するpublishを書いてみたいと思います。これは動作します： {-# LANGUAGE DataKinds #-} type Name = Text ty

0熱

1答えて

RabbitMq：メッセージ処理中に例外が発生したときにキューからメッセージが失われました。

私はRuby開発者です。私のプロジェクトでは、データがキューに入るとすぐに処理するためにrabbitMQを使用しています。私はRabbitMqと対話するためのインターフェースを提供するrabbitMQクライアントであるbunny gemを使用しています。私の問題は、例外が発生したとき、またはキューからデータを処理しているときにサーバーが突然停止したときに、キューからメッセージが失われることです。

0熱

1答えて

子プロセスでmsgrcv（）関数が失敗しました

現在、マスタプロセスと子プロセスの間でメッセージを送信しようとしています。私は重要なセクションを強制するためにメッセージの受け渡しを使用していますが、子プロセスのメッセージ受信機能が失敗しています。メッセージを送信する別の方法があるかどうかわかりません。私のメッセージ受信機能が親プロセスでメッセージを受け取っているので、ユーザープロセスが受信していない理由をデバッグするのに問題があります。 oss

1熱

1答えて

同じJMS相関IDを持つメッセージの重複

4人のサブスクライバを持つトピックにメッセージ（特定のの相関ID）を配置するアプリケーションがあります。メッセージが配置されると、メッセージは4人のサブスクライバによって消費され、応答を出していますキューと同じ相関ID（reply = 4messages）を持っています。メッセージがの重複相関IDを持っていると疑いがあります。要求に相関IDが含まれているメッセージを検索しているときにどのメッセージ