クラス DefaultStompSession
java.lang.ObjectSE
org.springframework.messaging.simp.stomp.DefaultStompSession
- 実装されたすべてのインターフェース:
ConnectionHandlingStompSession
、StompSession
、StompTcpConnectionHandler<byte[]>
、TcpConnectionHandler<byte[]>
ConnectionHandlingStompSession
のデフォルト実装。- 導入:
- 4.2
- 作成者:
- Rossen Stoyanchev
ネストされたクラスのサマリー
インターフェース org.springframework.messaging.simp.stomp.StompSession から継承されたネストクラス / インターフェース
StompSession.Receiptable, StompSession.Subscription
フィールドのサマリー
フィールドコンストラクターの概要
コンストラクターコンストラクター説明DefaultStompSession
(StompSessionHandler sessionHandler, StompHeaders connectHeaders) 新しいセッションを作成します。メソッドのサマリー
修飾子と型メソッド説明acknowledge
(StringSE messageId, boolean consumed) メッセージが消費されたかどうかにかかわらず、それぞれ ACK または NACK フレームを生成する確認応答を送信します。acknowledge
(StompHeaders headers, boolean consumed) void
afterConnected
(TcpConnection<byte[]> connection) 接続が正常に確立された後に呼び出されます。void
接続に失敗したときに呼び出されます。void
接続が閉じた後に呼び出されます。void
DISCONNECT フレームを送信してセッションを切断します。void
disconnect
(StompHeaders headers) ヘッダー付きのStompSession.disconnect()
の変種。STOMPCONNECT フレームで送信されるヘッダーを返します。設定されたMessageConverter
を返します。long
レシートの有効期限が切れる前に、構成された制限時間を返します。セッションが使用可能になったときに完了するフューチャーを返します。設定されたセッションハンドラーを返します。セッションの ID を返します。構成済みの TaskScheduler を受け取り、レシート追跡に使用します。void
接続の失敗を処理します。void
handleMessage
(Message<byte[]> message) リモートホストから受信したメッセージを処理します。boolean
受信ヘッダーを自動的に追加するかどうか。boolean
セッションが接続されているかどうか。MessageConverter
を使用してペイロードをbyte[]
に変換し、指定された宛先にメッセージを送信します。send
(StompHeaders headers, ObjectSE payload) 宛先だけではなく、完全なStompHeaders
を備えたStompSession.send(String, Object)
のオーバーロードバージョン。void
setAutoReceipt
(boolean autoReceiptEnabled) 有効にすると、このセッションの今後のsend
およびsubscribe
操作に受信ヘッダーが自動的に追加され、サーバーが RECEIPT を返します。void
setMessageConverter
(MessageConverter messageConverter) オブジェクト型または予期されるオブジェクト型と "content-type" ヘッダーに基づいて、受信メッセージと発信メッセージのペイロードをbyte[]
との間で変換するために使用するMessageConverter
を設定します。void
setReceiptTimeLimit
(long receiptTimeLimit) レシートが期限切れになるまでの時間をミリ秒単位で構成します。void
setTaskScheduler
(TaskScheduler taskScheduler) 領収書の追跡に使用する TaskScheduler を構成します。subscribe
(StringSE destination, StompFrameHandler handler) SUBSCRIBE フレームを送信して所定の宛先にサブスクライブし、指定されたStompFrameHandler
で受信メッセージを処理します。subscribe
(StompHeaders headers, StompFrameHandler handler) 宛先だけではなく、完全なStompHeaders
を備えたStompSession.subscribe(String, StompFrameHandler)
のオーバーロードバージョン。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.messaging.simp.stomp.ConnectionHandlingStompSession から継承されたメソッド
getSessionFuture
フィールドの詳細
EMPTY_PAYLOAD
public static final byte[] EMPTY_PAYLOAD空のペイロード。
コンストラクターの詳細
DefaultStompSession
新しいセッションを作成します。- パラメーター:
sessionHandler
- セッションのアプリケーションハンドラーconnectHeaders
- STOMP CONNECT フレームのヘッダー
メソッドの詳細
getSessionId
インターフェースからコピーされた説明:StompSession
セッションの ID を返します。- 次で指定:
- インターフェース
StompSession
のgetSessionId
- 次で指定:
- インターフェース
StompTcpConnectionHandler<byte[]>
のgetSessionId
getConnectHeaders
インターフェースからコピーされた説明:StompTcpConnectionHandler
STOMPCONNECT フレームで送信されるヘッダーを返します。- 次で指定:
- インターフェース
StompTcpConnectionHandler<byte[]>
のgetConnectHeaders
getSessionHandler
設定されたセッションハンドラーを返します。getSession
インターフェースからコピーされた説明:ConnectionHandlingStompSession
セッションが使用可能になったときに完了するフューチャーを返します。- 次で指定:
- インターフェース
ConnectionHandlingStompSession
のgetSession
setMessageConverter
オブジェクト型または予期されるオブジェクト型と "content-type" ヘッダーに基づいて、受信メッセージと発信メッセージのペイロードをbyte[]
との間で変換するために使用するMessageConverter
を設定します。デフォルトでは、
SimpleMessageConverter
が構成されています。- パラメーター:
messageConverter
- 使用するメッセージコンバーター
getMessageConverter
設定されたMessageConverter
を返します。setTaskScheduler
領収書の追跡に使用する TaskScheduler を構成します。getTaskScheduler
構成済みの TaskScheduler を受け取り、レシート追跡に使用します。setReceiptTimeLimit
public void setReceiptTimeLimit(long receiptTimeLimit) レシートが期限切れになるまでの時間をミリ秒単位で構成します。デフォルトでは 15,000 (15 秒に設定されています)。
getReceiptTimeLimit
public long getReceiptTimeLimit()レシートの有効期限が切れる前に、構成された制限時間を返します。setAutoReceipt
public void setAutoReceipt(boolean autoReceiptEnabled) インターフェースからコピーされた説明:StompSession
有効にすると、このセッションの今後のsend
およびsubscribe
操作に受信ヘッダーが自動的に追加され、サーバーが RECEIPT を返します。アプリケーションは、操作から返されたReceiptable
を使用して、領収書を追跡できます。StompHeaders
を受け入れるオーバーロードされたメソッドを使用して、受信ヘッダーを手動で追加することもできます。- 次で指定:
- インターフェース
StompSession
のsetAutoReceipt
isAutoReceiptEnabled
public boolean isAutoReceiptEnabled()受信ヘッダーを自動的に追加するかどうか。isConnected
public boolean isConnected()インターフェースからコピーされた説明:StompSession
セッションが接続されているかどうか。- 次で指定:
- インターフェース
StompSession
のisConnected
send
インターフェースからコピーされた説明:StompSession
MessageConverter
を使用してペイロードをbyte[]
に変換し、指定された宛先にメッセージを送信します。- 次で指定:
- インターフェース
StompSession
のsend
- パラメーター:
destination
- メッセージの送信先payload
- メッセージペイロード- 戻り値:
- 領収書を追跡するための Receiptable
send
インターフェースからコピーされた説明:StompSession
宛先だけではなく、完全なStompHeaders
を備えたStompSession.send(String, Object)
のオーバーロードバージョン。ヘッダーには宛先が含まれている必要があり、ブローカーがサブスクライバーに伝搬するための「コンテンツ型」やカスタムヘッダーなどの他のヘッダー、またはブローカー固有の非標準ヘッダーが含まれる場合もあります。- 次で指定:
- インターフェース
StompSession
のsend
- パラメーター:
headers
- メッセージヘッダーpayload
- メッセージペイロード- 戻り値:
- 領収書を追跡するための Receiptable
subscribe
インターフェースからコピーされた説明:StompSession
SUBSCRIBE フレームを送信して所定の宛先にサブスクライブし、指定されたStompFrameHandler
で受信メッセージを処理します。- 次で指定:
- インターフェース
StompSession
のsubscribe
- パラメーター:
destination
- 購読する宛先handler
- 受信したメッセージのハンドラー- 戻り値:
- 領収書の登録解除および / または追跡に使用するハンドル
subscribe
インターフェースからコピーされた説明:StompSession
宛先だけではなく、完全なStompHeaders
を備えたStompSession.subscribe(String, StompFrameHandler)
のオーバーロードバージョン。- 次で指定:
- インターフェース
StompSession
のsubscribe
- パラメーター:
headers
- サブスクライブされたメッセージフレームのヘッダーhandler
- 受信したメッセージのハンドラー- 戻り値:
- 領収書の登録解除および / または追跡に使用するハンドル
acknowledge
インターフェースからコピーされた説明:StompSession
メッセージが消費されたかどうかにかかわらず、それぞれ ACK または NACK フレームを生成する確認応答を送信します。注意 : サブスクライブするときにこれを使用するには、これを使用するために、
ack
ヘッダーを "client" または "client-individual" に設定する必要があります。- 次で指定:
- インターフェース
StompSession
のacknowledge
- パラメーター:
messageId
- メッセージの IDconsumed
- メッセージが消費されたかどうか- 戻り値:
- 領収書を追跡するための Receiptable
acknowledge
インターフェースからコピーされた説明:StompSession
- 次で指定:
- インターフェース
StompSession
のacknowledge
- パラメーター:
headers
- ACK または NACK メッセージフレームのヘッダーconsumed
- メッセージが消費されたかどうか- 戻り値:
- 領収書を追跡するための Receiptable
disconnect
public void disconnect()インターフェースからコピーされた説明:StompSession
DISCONNECT フレームを送信してセッションを切断します。- 次で指定:
- インターフェース
StompSession
のdisconnect
disconnect
インターフェースからコピーされた説明:StompSession
ヘッダー付きのStompSession.disconnect()
の変種。- 次で指定:
- インターフェース
StompSession
のdisconnect
- パラメーター:
headers
- 切断メッセージフレームのヘッダー
afterConnected
インターフェースからコピーされた説明:TcpConnectionHandler
接続が正常に確立された後に呼び出されます。- 次で指定:
- インターフェース
TcpConnectionHandler<byte[]>
のafterConnected
- パラメーター:
connection
- 接続
afterConnectFailure
インターフェースからコピーされた説明:TcpConnectionHandler
接続に失敗したときに呼び出されます。- 次で指定:
- インターフェース
TcpConnectionHandler<byte[]>
のafterConnectFailure
- パラメーター:
ex
- 例外
handleMessage
インターフェースからコピーされた説明:TcpConnectionHandler
リモートホストから受信したメッセージを処理します。- 次で指定:
- インターフェース
TcpConnectionHandler<byte[]>
のhandleMessage
- パラメーター:
message
- メッセージ
handleFailure
インターフェースからコピーされた説明:TcpConnectionHandler
接続の失敗を処理します。- 次で指定:
- インターフェース
TcpConnectionHandler<byte[]>
のhandleFailure
- パラメーター:
ex
- 例外
afterConnectionClosed
public void afterConnectionClosed()インターフェースからコピーされた説明:TcpConnectionHandler
接続が閉じた後に呼び出されます。- 次で指定:
- インターフェース
TcpConnectionHandler<byte[]>
のafterConnectionClosed