public interface QueueSession extends Session
QueueSession
オブジェクトは、QueueReceiver
、QueueSender
、QueueBrowser
、TemporaryQueue
オブジェクトを作成するためのメソッドを提供します。QueueSession
の終了時に受信されましたが確認応答されていないメッセージがある場合、これらのメッセージは保持され、コンシューマーが次にキューにアクセスしたときに再配信されます。
QueueSession
は、ポイントツーポイント固有のオブジェクトを作成するために使用されます。通常は、Session
オブジェクトを使用します。QueueSession
は、既存のコードをサポートするために使用されます。Session
オブジェクトを使用すると、プログラミングモデルが簡素化され、2 つのメッセージングドメインでトランザクションを使用できるようになります。
QueueSession
を使用して、パブリッシュ / サブスクライブドメインに固有のオブジェクトを作成することはできません。次のメソッドは Session
から継承しますが、QueueSession
から使用する場合は IllegalStateException
をスローする必要があります。
createDurableSubscriber
createDurableConsumer
createSharedConsumer
createSharedDurableConsumer
createTemporaryTopic
createTopic
unsubscribe
Session
, QueueConnection.createQueueSession(boolean, int)
, XAQueueSession.getQueueSession()
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
修飾子と型 | メソッドと説明 |
---|---|
QueueBrowser | createBrowser(Queue queue) QueueBrowser オブジェクトを作成して、指定されたキューのメッセージを確認します。 |
QueueBrowser | createBrowser(Queue queue, StringSE messageSelector) QueueBrowser オブジェクトを作成して、メッセージセレクターを使用して、指定されたキューのメッセージを確認します。 |
Queue | createQueue(StringSE queueName) Queue 名を指定してキュー ID を作成します。 |
QueueReceiver | createReceiver(Queue queue) 指定されたキューからメッセージを受信する QueueReceiver オブジェクトを作成します。 |
QueueReceiver | createReceiver(Queue queue, StringSE messageSelector) メッセージセレクターを使用して、指定されたキューからメッセージを受信する QueueReceiver オブジェクトを作成します。 |
QueueSender | createSender(Queue queue) 指定されたキューにメッセージを送信する QueueSender オブジェクトを作成します。 |
TemporaryQueue | createTemporaryQueue() TemporaryQueue オブジェクトを作成します。 |
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener, unsubscribe
Queue createQueue(StringSE queueName) throws JMSException
Queue
名を指定してキュー ID を作成します。この機能は、クライアントがキュー ID を動的に操作する必要があるまれなケースのために提供されています。プロバイダー固有の名前でキュー ID を作成できます。この機能に依存するクライアントは移植できません。
このメソッドは物理的なキューを作成するためのものではないことに注意してください。キューの物理的な作成は管理タスクであり、Jakarta Messaging API によって開始されません。1 つの例外は一時的なキューの作成で、これは createTemporaryQueue
メソッドで実行されます。
Session
の createQueue
queueName
- この Queue
の名前 Queue
JMSException
- 内部エラーのためにセッションがキューの作成に失敗した場合。QueueReceiver createReceiver(Queue queue) throws JMSException
QueueReceiver
オブジェクトを作成します。queue
- アクセスする Queue
QueueReceiver
オブジェクト JMSException
- 内部エラーのためにセッションがレシーバーの作成に失敗した場合。InvalidDestinationException
- 無効なキューが指定された場合。QueueReceiver createReceiver(Queue queue, StringSE messageSelector) throws JMSException
QueueReceiver
オブジェクトを作成します。queue
- アクセスする Queue
messageSelector
- メッセージセレクター式に一致するプロパティを持つメッセージのみが配信されます。null または空の文字列の値は、メッセージコンシューマーにメッセージセレクタがないことを示します。QueueReceiver
オブジェクト JMSException
- 内部エラーのためにセッションがレシーバーの作成に失敗した場合。InvalidDestinationException
- 無効なキューが指定された場合。InvalidSelectorException
- メッセージセレクタが無効な場合。QueueSender createSender(Queue queue) throws JMSException
QueueSender
オブジェクトを作成します。queue
- アクセスする Queue
。これが不明なプロデューサーの場合は nullQueueSender
オブジェクト。JMSException
- 内部エラーのためにセッションが送信者の作成に失敗した場合。InvalidDestinationException
- 無効なキューが指定された場合。QueueBrowser createBrowser(Queue queue) throws JMSException
QueueBrowser
オブジェクトを作成して、指定されたキューのメッセージを確認します。Session
の createBrowser
queue
- アクセスする Queue
QueueBrowser
オブジェクト。JMSException
- 内部エラーのためにセッションがブラウザーの作成に失敗した場合。InvalidDestinationException
- 無効なキューが指定された場合。QueueBrowser createBrowser(Queue queue, StringSE messageSelector) throws JMSException
QueueBrowser
オブジェクトを作成して、メッセージセレクターを使用して、指定されたキューのメッセージを確認します。Session
の createBrowser
queue
- アクセスする Queue
messageSelector
- メッセージセレクター式に一致するプロパティを持つメッセージのみが配信されます。null または空の文字列の値は、メッセージコンシューマーにメッセージセレクタがないことを示します。QueueBrowser
オブジェクト。JMSException
- 内部エラーのためにセッションがブラウザーの作成に失敗した場合。InvalidDestinationException
- 無効なキューが指定された場合。InvalidSelectorException
- メッセージセレクタが無効な場合。TemporaryQueue createTemporaryQueue() throws JMSException
TemporaryQueue
オブジェクトを作成します。それが以前に削除されない限り、その存続期間は QueueConnection
の存続期間になります。Session
の createTemporaryQueue
JMSException
- 内部エラーのためにセッションが一時キューの作成に失敗した場合。Copyright © 2019 Eclipse Foundation.
Use is subject to license terms.