public interface ConnectionConsumerConnection オブジェクトは、ConnectionConsumer を作成するための特別な機能を提供します（オプション）。消費するメッセージは、Destination とメッセージセレクターによって指定されます。さらに、ConnectionConsumer には、メッセージの処理に使用する ServerSessionPool を指定する必要があります。 通常、トラフィックが少ない場合、ConnectionConsumer はプールから ServerSession を取得し、単一のメッセージをロードして開始します。トラフィックが増加すると、メッセージがバックアップされる可能性があります。これが発生した場合、ConnectionConsumer は各 ServerSession に複数のメッセージをロードできます。これにより、スレッドコンテキストの切り替えが減り、メッセージ処理の直列化を犠牲にしてリソースの使用が最小限に抑えられます。
Connection.createConnectionConsumer(jakarta.jms.Destination, java.lang.String, jakarta.jms.ServerSessionPool, int), Connection.createDurableConnectionConsumer(jakarta.jms.Topic, java.lang.String, java.lang.String, jakarta.jms.ServerSessionPool, int), QueueConnection.createConnectionConsumer(jakarta.jms.Queue, java.lang.String, jakarta.jms.ServerSessionPool, int), TopicConnection.createConnectionConsumer(jakarta.jms.Topic, java.lang.String, jakarta.jms.ServerSessionPool, int), TopicConnection.createDurableConnectionConsumer(jakarta.jms.Topic, java.lang.String, java.lang.String, jakarta.jms.ServerSessionPool, int)| 修飾子と型 | メソッドと説明 |
|---|---|
void | close() 接続コンシューマーを閉じます。 |
ServerSessionPool | getServerSessionPool() この接続コンシューマーに関連付けられているサーバーセッションプールを取得します。 |
ServerSessionPool getServerSessionPool() throws JMSException
JMSException - Jakarta Messaging プロバイダーが、内部エラーのためにこのコンシューマーに関連付けられたサーバーセッションプールを取得できない場合。void close()
throws JMSExceptionプロバイダーは Java 仮想マシンの外部の接続コンシューマーに代わって一部のリソースを割り当てる可能性があるため、クライアントはこれらのリソースが不要なときに閉じる必要があります。最終的にこれらのリソースを再利用するためにガベージコレクションに依存することは、タイムリーではない場合があります。
JMSException - Jakarta Messaging プロバイダーが接続コンシューマーに代わってリソースを解放できない場合、または接続コンシューマーを閉じることができない場合。Copyright © 2018,2020 Eclipse Foundation.
Use is subject to license terms.