message-queue

0熱

1答えて

メッセージキューを構築していますが、現在、テンプレートクラスを使用する2種類のメッセージがあります。しかし、これは（上記のコードで fromMessageのために適切な DataMessage<std::string>に Messageをキャスト）は、内部メッセージの処理中に型キャストを行うに私を導き、私はこの Message toMessage(MESSAGE_GET_NAME); DataM

0熱

1答えて

エンドポイント間でラクダを渡すオブジェクト

概要。私のラクダのセットアップは、2つのサービス方法を呼び出します。最初の応答が2番目の応答に渡され、最後の応答がjsonのWebページとして出力されます。かなりシンプルすぎるものはありません。さらに詳しい説明があります。 Method_1。 scanIdを受け取ります。これは正常に動作します。これは、ScheduledScan .class Method_2というオブジェクトを生成します。

1熱

2答えて

マイクロサービスがサードパーティベンダに公開されたメッセージキューをラップする必要がありますか？

私は、私たちにメッセージをプッシュする必要のある第三者のベンダーを持っています。私は、これらのメッセージをメッセージキューに入れることを検討しています。なぜなら、待ち行列で行動を起こしてトラフィックに圧倒される必要のあるマイクロサービスを望んでいないからです。キューにメッセージを入れるためのアクセス権をサードパーティに与えること、またはキューの周りにRESTfulマイクロサービスのようにラップす

0熱

2答えて

カフカを設定して、最古のメッセージや最新のメッセージを読むことができます。以前のオフセットから読み取る必要がある場合に備えて、追加オプションを含めるにはどうすればよいですか？これを行う必要があるのは、先に処理ロジックが間違っているため、読み取られた以前のメッセージを再度処理する必要があるからです。

0熱

1答えて

重複したメッセージを削除するRabbitMQプラグイン

私は文書の生成のためにRabbitMQキューを持っています。基本的には、各文書にtypeとstate（新規作成、処理中）がありますので、type.stateのようなルーティングキーでトピック交換を使用します。文書が変更されるたびに、私は最後の文書記述を含むメッセージを交換所に送り、それは十分に機能する。は、しかし、時には文書が2回処理することができます。ユーザーは、新しい文書を送信します。新し

0熱

1答えて

実行時にLinuxメッセージキューのアクセス許可を変更する

メッセージキューは、デフォルトのアクセス許可で "mq_open"関数を使用して実装されています。私はmode引数を使ってメッセージキューの許可を設定できることを知っています。しかし、いったんシステムをコンパイルすると、もう一度バイナリをコンパイルするのではなく、他のlinuxコマンドを使って（ランタイム中に）メッセージキューのパーミッションを変更する可能性はありますか？

1熱

2答えて

ハンドラーを使用してAndroidでsendMessageを送信する

Dear。私はAndroidの開発を勉強しています。私はHandlers/LoopersとMessageQueueに固執しています。は、ドキュメントによると、ハンドラは、別のスレッドへのsendMessageとポスト（Runnableを）することができますので、私は次のことを試してみた： public class MyThread extends Thread { public MyT

0熱

1答えて

IBM MQのリスナー

IBM MQキューのリスナーを作成しようとしています。ネイティブAPIを使用してキューに配置されたときにメッセージを読み取るようにしています。毎秒GETを実行するには、Thread/TimerTaskを使用する方がよいでしょうか。認証目的でCCDT、ユーザー名とパスワードを使用する必要があります。デフォルトのリスナーはありますか？コード MQMessage theMessage = new

0熱

1答えて

メッセージキューのないプロセス間（サービス）通信

マイクロサービスアーキテクチャに基づいたアプリケーションを開発したいと考えています。さまざまなサービス間で非同期で通信するために、メッセージキュー（RabbitMQ、ActiveMQ、JMSなど）を使用する予定です。プロセス間通信を実現するためにメッセージキュー以外のアプローチはありますか？ありがとうございました。

1熱

1答えて

ServiceStack：IMessageServiceの依存関係注入オブジェクトの有効期間

IMessageService.RegisterHandler<T>(Func<IMessage<T>, object>)を実装するロジックがあります。メッセージキューの実行ブロックでは、Funq.Containerを使用してサービスを自動配線します。サービスのプロパティは依存関係注入されていましたが、スレッド間で共有されているようです。プロパティクラスは次のように定義されます。 _Contain