public interface QueueReceiver extends MessageConsumer
QueueReceiver
オブジェクトを使用して、キューに配信されたメッセージを受信します。 同じキューに複数の QueueReceiver
を設定することは可能ですが、Jakarta Messaging API は、メッセージが QueueReceiver
間でどのように分散されるかを定義していません。
QueueReceiver
がメッセージセレクターを指定している場合、選択されていないメッセージはキューに残ります。定義上、メッセージセレクターを使用すると、QueueReceiver
はメッセージをスキップできます。これは、スキップされたメッセージが最終的に読み取られるときに、読み取りの全体的な順序が、各メッセージプロデューサーによって定義された部分的な順序を保持しないことを意味します。メッセージセレクターのない QueueReceiver
のみが、メッセージプロデューサーの順序でメッセージを読み取ります。
MessageConsumer
の作成は、QueueReceiver
の作成と同じ機能を提供します。新しいコードを作成するには、MessageConsumer
オブジェクトをお勧めします。QueueReceiver
は、既存のコードをサポートするために提供されています。
Session.createConsumer(Destination, String)
, Session.createConsumer(Destination)
, QueueSession.createReceiver(Queue, String)
, QueueSession.createReceiver(Queue)
, MessageConsumer
修飾子と型 | メソッドと説明 |
---|---|
Queue | getQueue() このキューレシーバーに関連付けられている Queue を取得します。 |
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
Queue getQueue() throws JMSException
Queue
を取得します。Queue
JMSException
- Jakarta Messaging プロバイダーが、内部エラーのためにこのキューレシーバーのキューを取得できない場合。Copyright © 2019 Eclipse Foundation.
Use is subject to license terms.