問題タブ [activemq-artemis]

Apache ActiveMQ Artemis プロジェクト ( https://github.com/apache/activemq-artemis ) の git リポジトリのクローンを作成し、次のように入力しました。

次のようなログ メッセージを見て驚いた

egartemis-core-clientは最初にクローンした git リポジトリに含まれているので、maven はそこからビルドするだけだと思っていました。

そうすれば、コア クライアント ソースに変更を加えると、それらが統合テストによって検出されます。

代わりに、maven はリポジトリから jar をダウンロードしています。

質問: 常に git リポジトリにあるすべてのモジュールをビルドし、「真の」依存関係 (git リポジトリにないもの) のみをダウンロードするように maven を構成するにはどうすればよいですか?

ActiveMQ Artemis ブローカーで MQTT メッセージをインターセプトする方法を教えてもらえますか? マニュアルで提案されているように試しましたが、MQTT メッセージはインターセプトされません。ただし、メッセージの発行と購読は正常に機能しています。

インターセプター クラス:

addMQTTConnector メソッドの構成にインターセプターを追加します

ブローカー クラスの完全なコードは、https://codeshare.io/snZsBにあります。

MDBバージョン5.13.3を実行しているスタンドアロンのActiveMQ-Serverに接続するために、組み込みのActiveMQ Artemisを使用してwildfly 10サーバーに接続しようとしています。Artemis は、サポートされている ActiveMQ プロトコルのいずれとも通信できないようです。

ActiveMQ スタンドアロン ブローカーには次のものがありますtransportConnectors。

Wildfly MessageBeanには次のものがありますAnnotation。

接続先として選択したコネクタに応じて、ActiveMQ サーバーでさまざまなエラー メッセージが表示されます。

auto-endpointに接続すると、次のメッセージが表示されます。

エラー | 接続を受け入れることができませんでした: java.lang.IllegalStateException: ワイヤ形式を検出できませんでした

wildfly 側にエラーはありません。

Openwire-endpointに接続すると、次のメッセージが表示されます。

警告 | トランスポート接続: tcp://127.0.0.1:45000 に失敗しました: java.io.IOException: 不明なデータ型: 77

これにより、ワイルドフライ側でもエラーが発生します。

17:04:23,384 ERROR [org.apache.activemq.artemis.core.client] (Thread-16 (ActiveMQ-client-netty-threads-1716275972)) > AMQ214013: パケットのデコードに失敗しました: java.lang.IllegalArgumentException: AMQ119032 : 無効なタイプ: org.apache.activemq.artemis.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:413) で 1 org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder) で.java:60) org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:39) org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl) .java:324) org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingBufferHandler.bufferReceived(ClientSessionFactoryImpl.java:1105) で org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265) で io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) で io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java) :294) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846) で io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131) で io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) io java.lang.Thread.run(Thread.java: 745)実行 (Thread.java:745)実行 (Thread.java:745)

これを続けて、すべてのエンドポイントでエラー メッセージを受け取ることができました。実際、ActiveMQ-Artemis は、ActiveMQ でサポートされていないデータ形式で送信しています。

ActiveMQ-Artemis をスタンドアロンの ActiveMQ-Server に接続するには、どの手順を実行する必要がありますか?

私は ActiveMQ Artemis を WildFly10 に組み込み (付属しています)、Hawt.io 経由で監視したいと考えています。

私がしたこと：

• ActiveMQ Artemis が構成され、実行されている
• hawtio.war を配置ディレクトリにドロップしました。
• maven artemis-plugin でビルドしたものを削除し、名前を artemis-plugin.war に変更しました
• jolokia.warもドロップしました

スタンドアロン jar を試してみました - プラグイン ディレクトリを作成し、そこに artemis-plugin.war を配置しました。

jolokia に接続すると、WildFly の CPU 使用率 (およびそのようなもの) が表示されます。JMX 経由でキューを確認できますが、それでも Artemis で成功します。

hawtio はプラグインを認識しませんhawtio はプラグインを認識しませんが、ロードされました:

「アルテミス」タブがありません。http://0.0.0.0:8081/artemis-pluginに行くと、次のディレクトリが表示されます。

ディレクトリ: /artemis-plugin/

何か案は？

HA とフェイルオーバーをサポートする 2 つの ActiveMQ Artemis サーバーをセットアップしようとしています。しかし、ドキュメントとこの例でわかることは、コード内の各 Artemis ノードへの接続とセッションをセットアップする必要があるため、Artemis はスケーラブルではないということです。つまり、3 台目のサーバーを追加して Artemis を拡張したい場合、そのサーバーへの接続とセッションが存在するコードの新しいリリースを作成する必要がありますよね?

それはまた、障害が発生したサーバーが起動してクラスターに再び表示されたときに、新しい接続と新しいセッションを手動で作成する必要があることを意味しますか?

Artemis REST 機能を自分のプロジェクトの 1 つに統合するのに問題があります。より正確には、キューからメッセージを消費しようとするまでは、すべて問題ありません。

ドキュメントに記載されているプロセスに従っています。API は HATEOAS 原則に従います。つまり、基本的には、呼び出しに使用される URL へのハイパーリンクを返す API 呼び出しを使用します。

で構成されるプロセス

1. メッセージの公開
2. メッセージを消費するプルリソースを作成する
3. プルリソースを介して実際にメッセージを消費する

ポイント3までは正常に動作します。

エンドポイントを呼び出すと例外が発生し、消費するメッセージのタイプが正しくないという不平を言います。スタックトレースは次のとおりです。

このアプリケーションは、バージョン 1.1.0 の Artemis を含む wildfly 10 内で実行されます (artemis rest バージョン: 1.1.0)。

リクエストでメッセージのコンテンツ タイプを配信しようとしました。しかし、どのタイプを提供しても効果がないようです。

この時点で、私はエラーについてかなり無知です。誰かが私を正しい方向に向けてくれることを願っています。

前もってありがとう、トーマス。

Apache artemis でメッセージをスケジュールする必要があります

このストンプフレームを送信しようとしました:

しかし、それは機能していません。

私はこれらのプロパティを試しました..また、希望はありません:

スケジュールされたメッセージをサポートするようにブローカーを構成する必要があるかどうかはわかりません.. activemq. しかし、私もそれを試しました。bootstrap.xml にこのオプションを追加しました