public class UndertowWebSocketClient extends WebSocketClientSupport implements WebSocketClient
WebSocketClient の Undertow ベースの実装。logger| コンストラクターと説明 |
|---|
UndertowWebSocketClient(XnioWorker worker)WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡す XnioWorker を持つコンストラクター |
UndertowWebSocketClient(XnioWorker worker, ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> builderConsumer) 各 WebSocket 接続の WebSocketClient.ConnectionBuilder に対する追加の制御を提供する代替コンストラクター。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected io.undertow.websockets.client.WebSocketClient.ConnectionBuilder | createConnectionBuilder(URISE url) 指定された URI の WebSocketClient.ConnectionBuilder を作成します。 |
reactor.core.publisher.Mono<VoidSE> | execute(URISE url, HttpHeaders headers, WebSocketHandler handler) カスタムヘッダーを持つ WebSocketClient.execute(URI, WebSocketHandler) のバリアント。 |
reactor.core.publisher.Mono<VoidSE> | execute(URISE url, WebSocketHandler handler) 指定された URL に対してハンドシェイクリクエストを実行し、指定されたハンドラーで結果の WebSocket セッションを処理します。 |
ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> | getConnectionBuilderConsumer() 設定された Consumer<ConnectionBuilder を返します。 |
int | getPoolBufferSize()Undertow の WebSocketClient ByteBufferPool のサイズを返します。 |
XnioWorker | getXnioWorker() 設定された XnioWorker を返します。 |
void | setPoolBufferSize(int poolBufferSize)WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡す ByteBufferPool のサイズを構成します。 |
afterHandshake, beforeHandshakecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic UndertowWebSocketClient(XnioWorker worker)
WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡す XnioWorker を持つコンストラクター worker - Xnio ワーカー public UndertowWebSocketClient(XnioWorker worker, ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> builderConsumer)
WebSocketClient.ConnectionBuilder に対する追加の制御を提供する代替コンストラクター。worker - ConnectionBuilder の作成に使用する Xnio ワーカー builderConsumer - ConnectionBuilder を構成するコンシューマー public XnioWorker getXnioWorker()
XnioWorker を返します。public ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> getConnectionBuilderConsumer()
Consumer<ConnectionBuilder を返します。public void setPoolBufferSize(int poolBufferSize)
WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡す ByteBufferPool のサイズを構成します。デフォルトでは、バッファサイズは 8192 に設定されています。
public int getPoolBufferSize()
ByteBufferPool のサイズを返します。public reactor.core.publisher.Mono<VoidSE> execute(URISE url, WebSocketHandler handler)
WebSocketClientWebSocketClient の execute url - ハンドシェイク URLhandler - WebSocket セッションのハンドラー Mono<Void> の完了。public reactor.core.publisher.Mono<VoidSE> execute(URISE url, HttpHeaders headers, WebSocketHandler handler)
WebSocketClientWebSocketClient.execute(URI, WebSocketHandler) のバリアント。WebSocketClient の execute url - ハンドシェイク URLheaders - ハンドシェイクリクエストのカスタムヘッダー handler - WebSocket セッションのハンドラー Mono<Void> の完了。protected io.undertow.websockets.client.WebSocketClient.ConnectionBuilder createConnectionBuilder(URISE url)
WebSocketClient.ConnectionBuilder を作成します。 デフォルトの実装では、構成済みの XnioWorker および getPoolBufferSize() を使用してビルダーを作成し、構築時に提供される consumer に渡します。