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, setMessageListenerQueue getQueue() throws JMSException
Queue を取得します。QueueJMSException - Jakarta Messaging プロバイダーが、内部エラーのためにこのキューレシーバーのキューを取得できない場合。Copyright © 2018,2020 Eclipse Foundation.
Use is subject to license terms.