1

フェールオーバーと JDBC を使用して ActiveMQ でいくつかのテストを行っています。

死んだコンシューマーで保留中のメッセージが蓄積されることが起こります。コンシューマーには JDBC 挿入クエリが含まれています。

コンシューマ フローは次のようになります: JMS (インバウンド) -> JDBC (挿入)

保留中のメッセージが消費されるのを待った後、コンシューマーを起動してメッセージの取得を開始しますが、データの JDBC 挿入を実行しようとすると、「MySQL_Connector が停止しました」というメッセージが表示されます。

それはなぜです?どうすればこれを解決できますか? JMSインバウンドにJDBCが開始するのを「待つ」ように指示する方法はありますか?

ありがとう。

4

1 に答える 1