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, 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 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_SIZEpublic 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)
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 および ByteBufferPool を使用してビルダーを作成し、構築時に提供される consumer に渡します。