パッケージ jakarta.jms

インターフェース QueueReceiver

  • すべてのスーパーインターフェース:
    AutoCloseableSE, MessageConsumer
    public interface QueueReceiver
extends MessageConsumer
    クライアントは、QueueReceiver オブジェクトを使用して、キューに配信されたメッセージを受信します。

    同じキューに複数の QueueReceiver を設定することは可能ですが、Jakarta Messaging API は、メッセージが QueueReceiver 間でどのように分散されるかを定義していません。

    QueueReceiver がメッセージセレクターを指定している場合、選択されていないメッセージはキューに残ります。定義上、メッセージセレクターを使用すると、QueueReceiver はメッセージをスキップできます。これは、スキップされたメッセージが最終的に読み取られるときに、読み取りの全体的な順序が、各メッセージプロデューサーによって定義された部分的な順序を保持しないことを意味します。メッセージセレクターのない QueueReceiver のみが、メッセージプロデューサーの順序でメッセージを読み取ります。

    MessageConsumer の作成は、QueueReceiver の作成と同じ機能を提供します。新しいコードを作成するには、MessageConsumer オブジェクトをお勧めします。QueueReceiver は、既存のコードをサポートするために提供されています。

    導入:
    JMS 1.0
    バージョン:
    Jakarta Messaging 2.0
    関連事項:
    Session.createConsumer(Destination, String), Session.createConsumer(Destination), QueueSession.createReceiver(Queue, String), QueueSession.createReceiver(Queue), MessageConsumer

    • メソッドの詳細

      • getQueue

        Queue getQueue()
        throws JMSException
        このキューレシーバーに関連付けられている Queue を取得します。
        戻り値:
        このレシーバーの Queue
        例外:
        JMSException - Jakarta Messaging プロバイダーが、内部エラーのためにこのキューレシーバーのキューを取得できない場合。