2 つのキューで ActiveMQ 5.5.1 ブローカーを実行しています。クライアントはメッセージを生成し (多数の小さなものから大きなサイズのものまでさまざま)、それらをキュー 1 に入れます。ここから、コンシューマーはキューからメッセージを自分の速度 (メッセージのプリフェッチ = 0) でプルすることによって取得します。メッセージはトランザクションで送信されます。次に、消費者は何らかの計算を行い、計算が終了したら応答メッセージをキュー 2 に入れます。クライアントは、このキューから応答メッセージを取得します。
永続性は kahaDB を介して行われます。プロデューサー フロー制御は有効になっていますが、メモリ制限には達していません。
これは問題なく動作し、スループットも問題にならないようです。
ただし、ブローカーで次の 2 つの例外が見られることがあります。誰かが私に彼らが何を意味するのかヒントを教えてもらえますか? ActiveMQ のドキュメントや Google でも役に立つ情報は見つかりませんでした。
どうもありがとう、ジェイフ
警告 [ActiveMQ トランスポート: tcp:///140.39.12.159:40323] (TransportConnection.java:290) - org.apache.activemq.broker.TransportConnection.Service 非同期エラーが発生しました: java.lang.IllegalArgumentException: subscr
iption が存在しません: ID:XYZ:28807:2:1
java.lang.IllegalArgumentException: サブスクリプションが存在しません: ID:XYZ:28807:2:1
org.apache.activemq.broker.region.AbstractRegion.messagePull (AbstractRegion.java:389) で
org.apache.activemq.broker.region.RegionBroker.messagePull (RegionBroker.java:557) で
org.apache.activemq.broker.BrokerFilter.messagePull (BrokerFilter.java:81) で
org.apache.activemq.broker.BrokerFilter.messagePull (BrokerFilter.java:81) で
org.apache.activemq.broker.BrokerFilter.messagePull (BrokerFilter.java:81) で
org.apache.activemq.broker.MutableBrokerFilter.messagePull (MutableBrokerFilter.java:245) で
org.apache.activemq.broker.TransportConnection.processMessagePull (TransportConnection.java:470) で
org.apache.activemq.command.MessagePull.visit (MessagePull.java:43) で
org.apache.activemq.broker.TransportConnection.service (TransportConnection.java:306) で
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) で
org.apache.activemq.transport.TransportFilter.onCommand (TransportFilter.java:69) で
org.apache.activemq.transport.WireFormatNegotiator.onCommand (WireFormatNegotiator.java:113) で
org.apache.activemq.transport.InactivityMonitor.onCommand (InactivityMonitor.java:227) で
org.apache.activemq.transport.TransportSupport.doConsume (TransportSupport.java:83) で
org.apache.activemq.transport.tcp.TcpTransport.doRun (TcpTransport.java:220) で
org.apache.activemq.transport.tcp.TcpTransport.run (TcpTransport.java:202) で
java.lang.Thread.run(Thread.java:662) で
と
警告 [ActiveMQ トランスポート: tcp:///140.39.12.159:45179] (TransportConnection.java:290) - org.apache.activemq.broker.TransportConnection.Service 非同期エラーが発生しました: java.lang.IllegalStateException: からコンシューマーを検索できません登録されていない接続: ID:XYZ:31449
java.lang.IllegalStateException: 登録されていない接続からコンシューマを検索できません: ID:XYZ:31449
org.apache.activemq.broker.SingleTransportConnectionStateRegister.lookupConnectionState (SingleTransportConnectionStateRegister.java:83) で
org.apache.activemq.broker.TransportConnection.lookupConnectionState (TransportConnection.java:1423) で
org.apache.activemq.broker.TransportConnection.processMessagePull (TransportConnection.java:470) で
org.apache.activemq.command.MessagePull.visit (MessagePull.java:43) で
org.apache.activemq.broker.TransportConnection.service (TransportConnection.java:306) で
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) で
org.apache.activemq.transport.TransportFilter.onCommand (TransportFilter.java:69) で
org.apache.activemq.transport.WireFormatNegotiator.onCommand (WireFormatNegotiator.java:113) で
org.apache.activemq.transport.InactivityMonitor.onCommand (InactivityMonitor.java:227) で
org.apache.activemq.transport.TransportSupport.doConsume (TransportSupport.java:83) で
org.apache.activemq.transport.tcp.TcpTransport.doRun (TcpTransport.java:220) で
org.apache.activemq.transport.tcp.TcpTransport.run (TcpTransport.java:202) で
java.lang.Thread.run(Thread.java:662) で