問題タブ [broker]

埋め込みブローカーを開始するために、activemq サイトの例に従いました。

次に、次の URL に投稿して、ActiveMQ の REST 機能を使用します。

スタンドアロン ブローカーを使用して投稿を送信するとすべて正常に動作しますが、組み込みブローカーを使用するとプロセスがハングします。

アクティブな mq バージョン 5.8.0 を使用しています

私は何が欠けていますか？

ありがとう

0MQ を使用して一部のワーカーとクライアント間の通信のプロキシとして機能するブローカーを開発しようとしています。このタスクは promise なしで行うのは比較的簡単でしたが、promise の使用に不慣れなため、この例で promise を実装する方法を理解できません。

ブローカーのコード:

クライアントのコード:

クライアントはブローカーに接続し、メッセージを送信しますが、メッセージはブローカーによって処理されません。私が間違っていることについてのアイデアはありますか？どんな助けでも大歓迎です。

次のように、activeMQ 組み込みブローカーを初期化しています。

次に、Json 文字列を次の URL に投稿して、ActiveMQ の REST 機能を使用します。

次の例外が発生します。

組み込みブローカーが Json と連携するには、何らかの構成が必要になると思いますが、activeMQ のヘルプでそれに関する情報を見つけることができませんでした。

どうもありがとう！

同じサーバーに複数の ActiveMQ ブローカーをセットアップするために、[1] の正確な手順を省略しました。2 番目のインスタンスを開始すると、常に同じエラーが発生します。

私が気づいたことの 1 つは、両方のインスタンスの構成が同じであることです。たとえば、ポートなどの構成は、activemq.xml と jetty.xml の両方で同じです。

最初のインスタンスでクラッシュしないように、2 番目のインスタンスのポートも変更します。しかし、同じ例外が発生します。

https://sbforge.org/display/BITMAG/Running+multiple+activemq+instances+on+the+same+server

情報 | Apache ActiveMQ 5.9.0 (インスタンス 1、ID:udara-54224-1391513355578-0:1) がシャットダウンされました。org.apache.activemq.xbean.XBeanBrokerFactory$1@33e228bc の終了: 開始日 [2014 年 2 月 4 日火曜日 06:29:14 EST]; コンテキスト階層のルート WARN | コンテキストを閉じる際に LifecycleProcessor から例外がスローされるorg.apache.activemq.xbean.XBeanBrokerFactory$1@33e228bc: 開始日 [Tue Feb 04 06:29:14 EST 2014]; org.springframework.context.support.AbstractApplicationContext.getLifecycleProcessor(AbstractApplicationContext.java:360) のコンテキスト階層のルート org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1057) の org.springframework.context.support .AbstractApplicationContext.close(AbstractApplicationContext.java:1010) で org.apache.activemq.hooks.SpringContextHook.run(SpringContextHook.java:30) で org.apache.activemq.broker.BrokerService.stop(BrokerService.java:782) でorg.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:122) at org.apache.activemq.broker.BrokerService.start(BrokerService.java:574) at org.apache.activemq.xbean.

セットアップ: asp.net/c# に組み込まれたフォームがあり、送信時に XML がオブジェクト モデルをシリアル化し、その XML シリアル化されたデータを唯一のパラメーターとしてストアド プロシージャを呼び出します。ストアド プロシージャは、そのデータを SQL Broker キューに送信します。ブローカ キューに送信されるメッセージは、キューに設定されたメッセージ コントラクトに従う有効な XML である必要があります。そのメッセージは BizTalk によって取得され、それに応じて処理されます。

問題: 当初、私に提出されたデータは通常の英語の文字 (基本的に ASCII 文字セットに保持されている) だけでしたが、外国語の文字もサポートする必要があります。私のテストでは、外国語の文字 (中国語、アラビア語など) を含むものを送信しようとすると、キューでエラーが発生し、BizTalk に到達するメッセージが "?????" で終わることに気付きました。外国のキャラクターの代わりに。ドキュメントの先頭に utf=16 xml ヘッダーを追加しましたが、役に立たないようです。

質問: 着信 XML メッセージを nvarchar としてキャストしても、キューによって有効な XML と見なされる方法はありますか? キューの実際のタイプを変更したり、再作成したりしたくありません。キューに入れることができるように、ストアド プロシージャだけでメッセージを変更したいと思います。

よろしくお願いします。

MB フローからいくつかの MQ コマンドを発行する必要があります。行く方法は PCF コマンドを送信することですが、作成方法がわかりません。ポインタはありますか？セバスチャン。