messagebroker

0熱

1答えて

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

0熱

2答えて

IBM Integration Busとxsd：anyType

私はIIB v9 mxsdメッセージ定義を扱っています。 XML要素の1つをxsd：anyType型に定義したいと思います。しかし、私が選択できるタイプのリストでは、anySimpleTypeとanyUriのみが可能です（文字列、整数などの他のすべての型の他に）。この制限を回避するにはどうすればよいですか？

0熱

1答えて

既存のキューをCompositeQueueに変換するActiveMQ

私はできる限りこれを説明しようとします。 ActiveMQキューから受信したデータをいくつかの異なる場所に保存するので、それぞれの場所ごとにデータを処理できるように、複合キューを構築することに決めました。問題は、現在私が運用環境でキューを持っていることです。 Aという名前のキューをBとCという名前の仮想宛先を持つ複合キューに変更すると、既存のキューのすべてのデータが失われるようです。これは、起動

0熱

1答えて

MQTTを使用すると、localhost以外のすべてのユーザーのパブリケーションをブロックし、すべてのユーザーにサブスクリプションを公開することができますか？

私がしたいのは、ローカルホストからのみ公開されたデータを持つことです。しかし、Webのどのユーザーもそのトピックを購読できるようにする必要があります。MQTTを使用することは可能ですか？どうやって？もしそうでない場合は、この詳細をフルに満たすオプションがありますか？追加情報：投稿するMQTTプロトコルを使用します。 Websocketを使用して購読する。ブローカーとしてMosquitto

1熱

1答えて

カフカの_transaction_stateトピックからデータを読み取る0.11.0.1

特定のトランザクションIDのトランザクションがコミットされたかどうかを知るために、トランザクションのメタデータ（Kafka 0.11.0.1でサポートされている）を読みたいない。現在、_transactional_stateトピックからキーと値を取得していますが、エンコードされた形式です。キー= 10000000mmm、値= �� + '）あなたはTransactionLogMessageP

0熱

1答えて

rabbit mq用データベースのような永続ストアオプション

私たちはプロジェクトでメッセージブローカーとしてウサギMQを使用しています。私たちは、Rabbit MQの永続ストアに関するブログやドキュメントをいくつか取り上げました。メッセージストアには、メモリ、キューインデックス、およびディスク上のフラットファイルなどの既定のオプションがあります。私たちはメッセージの耐久性にもっと関心があるので、私たちはウサギのmqを使ってデータストアに最適な方法を探し

0熱

1答えて

Qpid Proton：2つの宛先にメッセージを送信

現在、私は単一のキュー "devQueue"にメッセージを送信できます。メッセージが「devQueue」に届くと、それは「localQueue」にも送られる必要があります。私はこの実装が挑戦的であると感じています。私は別のクラス "local_send"を "class1"クラスから呼び出そうとしましたので、 "localQueue"（下のコードに示すように）の他の行き先に接続できますが、運があり

0熱

1答えて

XMLNSのXMLNSCで属性をXMLの配列に設定する

属性がある場合はname="xxxxxx"属性をXML要素に追加することに成功していますが、繰り返し要素の配列は存在しません。たとえば、私は次の行で<Broker name="xxxxxx">要素を作成することができますを、次の行を持つXML要素の配列を作成することができます。 SET OutputRoot.XMLNSC.SystemDetails.BrokerDetails.Serve

0熱

1答えて

RabbitMQ遅い受信速度

私は、データプロデューサからデータを受け取り、処理する必要があるアプリケーションを作成する必要があります。私はメッセージブローカーとしてRabbitMQを選びました。私のテストでは、最良の結果ではないことが分かりました。送信 - 100 msg; プロデュース - 100 msg/s; 消費 - 6 msg/s; これを解決するには、listenerContainer.setAcknowledg