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