publish-subscribe

0熱

1答えて

これは適切な質問ではありませんが、出版/購読メッセージングシステムを実装するためのRabbitMQの機能に関する質問があります。私はそれが私が働いている会社のニーズに合うかどうかを確認するためのRabbitMQを調査しています、と私は、公式ドキュメントや、インターネット上のいずれかにこれらの質問への答えを見つけることができません。は、ことは可能です消費者は出版社のグループに加入することができます

0熱

1答えて

Vert.xのディスパッチイベントを他のインスタンスにのみ

ののインスタンスをいくつか持ち、特定のトピックをリッスンし、これらのインスタンスの1つから別のインスタンスにイベントをディスパッチしたいとします。問題は、その1つのインスタンスがディスパッチして同じイベントを消費することです。インスタンスが自分自身からメッセージを受信できないようにするにはどうすればよいですか？

0熱

1答えて

awsからのメッセージを公開する変更があったときにs3バケット

現在、私は聞いているクライアントにメッセージを公開するAWS IoTを持っています。しかし、S3バケットに変更があった場合でも、ラムダやSNSの仕組みと同じように、AWSがクライアントにメッセージを公開するようにしたいと考えています。トリガーポイントはS3バケットの修正でなければなりません。任意の提案は

3熱

1答えて

SubmissionPublisher on submitサブスクライバのonNextを呼び出さずに

ある間隔で、特定のクエリでツイートを取得します。これらのつぶやきは、それらのつぶやきを計算して操作するサービスに渡す必要があります。これらのサービスは私のパブリッシャーにサブスクライブされています。したがって、publisher.hasSubscribers（）はtrueを返します。しかし、サブミットまたはオファー機能は、サブスクライバのonNextを呼び出さない。「修正」として、私は加入者

0熱

1答えて

Azureで通知エンジンとしてRedis PubSubを使用する

IoTデバイス（温度センサー）がAzure IoT Hubにデータをプッシュするアプリケーションを構築しています。そして、このデータを読み込んでデータベースにプッシュするWebジョブがあります（rawと一緒にロールアップした後）。また、Webアプリケーションには、ユーザーが任意の部屋/エリアに登録できる機能が必要です。変更するたびに現在の温度を画面にプッシュする必要があります。これは、ユーザー

1熱

1答えて

IAPで保護されたApp EngineへのGoogle Pub/Subプッシュサブスクリプション

非常に基本的なPub/Subサブスクリプションをテストしています。 App EngineでPython Flexサービスを通じてデプロイしたAppにプッシュエンドポイントを設定しました。サービスは、アイデンティティアウェアプロキシが有効になっているプロジェクトにあります。 IAPは、ドメインを通じて認証されたユーザーを通過できるように構成されています。アプリで処理中のプッシュリクエストはありませ

0熱

1答えて

流星Jsに登録されているすべてのユーザーのデータを取得

meteorJSに登録されているすべてのユーザーのデータを取得します。私はいくつかのメソッドを試してみました（結果はコミットされたものです）。 db.users.findの結果（たぶん誰かが問題を知っている { "_id" : "uFdKrgSyeBr6msxsH", "createdAt" : ISODate("2017-10-19T12:35:26.930Z"), "services" :

0熱

1答えて

トピックの複数のリスナーは、Activemqでどのように動作しますか？

ActiveMq組み込みブローカーを使用しています。私はpub/subモデルを使用しています。トピックに登録されている複数のリスナーがあります。私はデフォルトのメッセージリスナーコンテナを使用しています。私はトピックと加入者の統計を取得し始めました。トピックのメッセージ数の統計値は常にゼロです。トピックのメッセージ数は、「見た限りでは、常にゼロです。これで、消費者の統計が宛先に届きました。

1熱

1答えて

ノードアプリケーションのすべてのフォロワーにリアルタイムフィードを取得する方法

node.jsとMongoDBにソーシャルネットワークタイプのアプリケーションを開発しています。 - のような機能を追加したいと思います。ユーザAがユーザBに従っている場合、ユーザBが何かを投稿すると、自動的にユーザAの壁に来るはずです！アプローチ1 - これは私が研究を持っているもの、ユーザBのチャネルを作成し、他のすべてのユーザーがそのチャネルにサブスクライブ今までとするとき、ユーザBポス

1熱

1答えて

JMSパブリッシャ/コンシューマのclientIDを設定する目的は何ですか？

耐久性のあるトピックのjmsトピックサブスクライバを書くときにclientIdとサブスクリプション名を設定する必要があることを理解しています。しかし、TOPICを公開するときにclientIDを設定する目的は何ですか？私は人々が出版社/消費者のためにクライアントIDを設定しているのを見ましたが、なぜそれが必要なのか誰も説明しませんでした。 ConnectionFactory conFactory