messagebroker

0熱

1答えて

私は一連のタスクを持っており、それぞれには一定の条件を満たす必要があります。例えば、タスクには100MbのRAMが必要です。また、私は労働者が配置されている複数のサーバーを持っています。各作業者には、どれだけのリソースがあるかを記述した設定があります。たとえば、タスクの実行に1GバイトのRAMを使用するワーカーもいます。各作業者が渡された作業の要件を満たすように、作業者間の配布作業のためのシステ

0熱

2答えて

複数のトピック・ストリング（IBM Integration Bus）にメッセージをパブリッシュする

MQ入力ノードを使用してメッセージを受信し、メッセージに含まれるソース・システムの値に基づいて、トピック・ストリングを形成し、メッセージ。私の流れがどのように見えるかです： MQInput - >計算 - >出版そして、私が使用してトピックの値を移入： SETをOutputRoot.Properties.Topic = 'ます。topicName /' || sourceName; メッセージに

1熱

1答えて

ルーターできないメッセージのキューを作成する

私はいくつかのJavaクライアントがダイレクト交換に公開しているメッセージを送信しています。それぞれのクライアントは、IDをルーティングキーとして（またはヘッダー交換として変更できるヘッダーとして）公開することができます。そのルートキーを使用してキューにバインドされている場合は、グローバルキューにパブリッシュするキューに発行します。私の質問は、キューからルート設定キー/ヘッダーをキューに入れる

-1熱

1答えて

CakeがBoostライブラリを見つけることができません（Windows）

私は現在、CMakeとBoost（C++）を使用してWindows上にApache qpidメッセージブローカーを構築しようとしています。 this fileで指定されているように、Windows上でQpidを設定する最初の手順を行った。変数BOOST_ROOTを "C：/ < Home>/Downloads/boost_1_61_0"に設定してCMakeがBoost Libraries（ランダム

0熱

2答えて

Apache Apolloブローカーの作成中にエラーが発生しました

Apache Apolloディストリビューションをダウンロードして解凍しました。described in their siteです。 ~/Developer/Web/MQTT/apache-apollo-1.7.1/bin/apollo create mybroker 私は端末で以下の出力を得ました。このコマンドでは、サブディレクトリetcを作成することになっています。なぜこのエラーが発生

1熱

1答えて

kafkaマルチブローカーの利点

こんにちは、私はかなり新しいapache kafkaです。私は多くの研究を行い、複数のブローカーの利点を見つけることができませんでした。 kafkaのドキュメント全体を読んだが、これに対する答えが見つかりませんでした。私は操作して保存する必要がある2つの異なるデバイスセットからデータを受信しています。どのデバイスデータが到着してから消費者が変わるかについては、マルチブローカー - 単一ト

0熱

1答えて

esqlを使用してキューが空であることを確認します。

キュー内のすべてのメッセージを消去するコードを作成しています。私は計算とGETノードを目的に使用しています。各メッセージをクリアしている間にメッセージをループし、キューが空のときにループを停止したいとします。私にMQGETノードはキューにはメッセージがありませんでしたプロセスルート場合はメッセージなし出力端子を、持っているこの

0熱

1答えて

Message Broker XMLNSCパーサー：引用符がエスケープされないようにする方法

メッセージブローカのXMLNSCパーサーを使用している場合、それは通常、以下のように、XMLで二重引用符をエスケープ： <MyElement>Some "Text" inside</MyElement> は、顧客の <MyElement>Some "Text" inside</MyElement> の一つとなり、このようなエスケープが彼らのために現実的な問題であると主張

2熱

1答えて

はESQL

私は DECLARE sp1 NAMESPACE 'http://www.ibm.com/space1'; /* Namespace declaration to associate prefix 'space1' with the namespace */ SET OutputRoot.XMLNS.TestCase.(XML.NamespaceDecl)xmlns:space1 = 'h

3熱

2答えて

BizTalkのサービスバスのようなメッセージブローカーが必要ですか？

データベースにCRMを接続したいのですが、BizTalkが最良の選択であると分かっています。私はBizTalkが独自のメッセージングシステムを持っていることを知っていますが、データの安定性を考えれば十分ですか？それとも、メッセージバスを間に置かなければなりませんか？