クラス 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) voidafterConnected(TcpConnection<byte[]> connection) 接続が正常に確立された後に呼び出されます。void接続に失敗したときに呼び出されます。void接続が閉じた後に呼び出されます。voidDISCONNECT フレームを送信してセッションを切断します。voiddisconnect(StompHeaders headers) ヘッダー付きのStompSession.disconnect()の変種。STOMPCONNECT フレームで送信されるヘッダーを返します。設定されたMessageConverterを返します。longレシートの有効期限が切れる前に、構成された制限時間を返します。セッションが使用可能になったときに完了するフューチャーを返します。設定されたセッションハンドラーを返します。セッションの ID を返します。構成済みの TaskScheduler を受け取り、レシート追跡に使用します。void接続の失敗を処理します。voidhandleMessage(Message<byte[]> message) リモートホストから受信したメッセージを処理します。boolean受信ヘッダーを自動的に追加するかどうか。booleanセッションが接続されているかどうか。MessageConverterを使用してペイロードをbyte[]に変換し、指定された宛先にメッセージを送信します。send(StompHeaders headers, ObjectSE payload) 宛先だけではなく、完全なStompHeadersを備えたStompSession.send(String, Object)のオーバーロードバージョン。voidsetAutoReceipt(boolean autoReceiptEnabled) 有効にすると、このセッションの今後のsendおよびsubscribe操作に受信ヘッダーが自動的に追加され、サーバーが RECEIPT を返します。voidsetMessageConverter(MessageConverter messageConverter) オブジェクト型または予期されるオブジェクト型と "content-type" ヘッダーに基づいて、受信メッセージと発信メッセージのペイロードをbyte[]との間で変換するために使用するMessageConverterを設定します。voidsetReceiptTimeLimit(long receiptTimeLimit) レシートが期限切れになるまでの時間をミリ秒単位で構成します。voidsetTaskScheduler(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
インターフェースからコピーされた説明:StompTcpConnectionHandlerSTOMPCONNECT フレームで送信されるヘッダーを返します。- 次で指定:
- インターフェース
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
インターフェースからコピーされた説明:StompSessionMessageConverterを使用してペイロードをbyte[]に変換し、指定された宛先にメッセージを送信します。- 次で指定:
- インターフェース
StompSessionのsend - パラメーター:
destination- メッセージの送信先payload- メッセージペイロード- 戻り値:
- 領収書を追跡するための Receiptable
send
インターフェースからコピーされた説明:StompSession宛先だけではなく、完全なStompHeadersを備えたStompSession.send(String, Object)のオーバーロードバージョン。ヘッダーには宛先が含まれている必要があり、ブローカーがサブスクライバーに伝搬するための「コンテンツ型」やカスタムヘッダーなどの他のヘッダー、またはブローカー固有の非標準ヘッダーが含まれる場合もあります。- 次で指定:
- インターフェース
StompSessionのsend - パラメーター:
headers- メッセージヘッダーpayload- メッセージペイロード- 戻り値:
- 領収書を追跡するための Receiptable
subscribe
インターフェースからコピーされた説明:StompSessionSUBSCRIBE フレームを送信して所定の宛先にサブスクライブし、指定された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()インターフェースからコピーされた説明:StompSessionDISCONNECT フレームを送信してセッションを切断します。- 次で指定:
- インターフェース
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