public class UndertowWebSocketClient extends ObjectSE implements WebSocketClient
WebSocketClient
の Undertow ベースの実装。コンストラクターと説明 |
---|
UndertowWebSocketClient(XnioWorker worker) WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡す XnioWorker を持つコンストラクター。 |
UndertowWebSocketClient(XnioWorker worker, io.undertow.connector.ByteBufferPool byteBufferPool, ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> builderConsumer) 各 WebSocket 接続の WebSocketClient.ConnectionBuilder に対する追加の制御を提供する代替コンストラクター。 |
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 セッションを処理します。 |
io.undertow.connector.ByteBufferPool | getByteBufferPool() このクライアントが新しく作成した WebSocket セッションに現在使用されている ByteBufferPool を返します。 |
ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> | getConnectionBuilderConsumer() 設定された Consumer<ConnectionBuilder> を返します。 |
XnioWorker | getXnioWorker() 設定された XnioWorker を返します。 |
void | setByteBufferPool(io.undertow.connector.ByteBufferPool byteBufferPool) ByteBufferPool を WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI) に渡すように設定します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public 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 UndertowWebSocketClient(XnioWorker worker, io.undertow.connector.ByteBufferPool byteBufferPool, ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> builderConsumer)
WebSocketClient.ConnectionBuilder
に対する追加の制御を提供する代替コンストラクター。worker
- ConnectionBuilder
の作成に使用する Xnio ワーカー byteBufferPool
- ConnectionBuilder
の作成に使用する ByteBufferPoolbuilderConsumer
- ConnectionBuilder
を構成するコンシューマー public XnioWorker getXnioWorker()
XnioWorker
を返します。public void setByteBufferPool(io.undertow.connector.ByteBufferPool byteBufferPool)
ByteBufferPool
を WebSocketClient.connectionBuilder(org.xnio.XnioWorker, io.undertow.connector.ByteBufferPool, java.net.URI)
に渡すように設定します。 デフォルトでは、バッファサイズ 8192 の間接 DefaultByteBufferPool
が使用されます。
DEFAULT_POOL_BUFFER_SIZE
public io.undertow.connector.ByteBufferPool getByteBufferPool()
ByteBufferPool
を返します。public ConsumerSE<io.undertow.websockets.client.WebSocketClient.ConnectionBuilder> getConnectionBuilderConsumer()
Consumer<ConnectionBuilder>
を返します。public reactor.core.publisher.Mono<VoidSE> execute(URISE url, WebSocketHandler handler)
WebSocketClient
WebSocketClient
の execute
url
- ハンドシェイク URLhandler
- WebSocket セッションのハンドラー Mono<Void>
の補完。public reactor.core.publisher.Mono<VoidSE> execute(URISE url, HttpHeaders headers, WebSocketHandler handler)
WebSocketClient
WebSocketClient.execute(URI, WebSocketHandler)
のバリアント。WebSocketClient
の execute
url
- ハンドシェイク URLheaders
- ハンドシェイクリクエストのカスタムヘッダー handler
- WebSocket セッションのハンドラー Mono<Void>
の補完。protected io.undertow.websockets.client.WebSocketClient.ConnectionBuilder createConnectionBuilder(URISE url)
WebSocketClient.ConnectionBuilder
を作成します。 デフォルトの実装では、構成済みの XnioWorker
および ByteBufferPool
を使用してビルダーを作成し、構築時に提供される consumer
に渡します。