public class ReactorNettyWebSocketClient extends java.lang.Object implements WebSocketClient
WebSocketClient
implementation for use with Reactor Netty.Modifier and Type | Field and Description |
---|---|
private HttpClient |
httpClient |
private static Log |
logger |
Constructor and Description |
---|
ReactorNettyWebSocketClient()
Default constructor.
|
ReactorNettyWebSocketClient(HttpClient httpClient)
Constructor that accepts an existing
HttpClient builder. |
Modifier and Type | Method and Description |
---|---|
<any> |
execute(java.net.URI url,
HttpHeaders requestHeaders,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
<any> |
execute(java.net.URI url,
WebSocketHandler handler)
Execute a handshake request to the given url and handle the resulting
WebSocket session with the given handler.
|
HttpClient |
getHttpClient()
Return the configured
HttpClient . |
private void |
setNettyHeaders(HttpHeaders httpHeaders,
io.netty.handler.codec.http.HttpHeaders nettyHeaders) |
private HttpHeaders |
toHttpHeaders(WebsocketInbound inbound) |
private static final Log logger
private final HttpClient httpClient
public ReactorNettyWebSocketClient()
public ReactorNettyWebSocketClient(HttpClient httpClient)
HttpClient
builder.public HttpClient getHttpClient()
HttpClient
.public <any> execute(java.net.URI url, WebSocketHandler handler)
WebSocketClient
execute
in interface WebSocketClient
url
- the handshake urlhandler
- the handler of the WebSocket sessionMono<Void>
to indicate the outcome of the
WebSocket session handling.public <any> execute(java.net.URI url, HttpHeaders requestHeaders, WebSocketHandler handler)
WebSocketClient
WebSocketClient.execute(URI, WebSocketHandler)
with custom headers.execute
in interface WebSocketClient
url
- the handshake urlrequestHeaders
- custom headers for the handshake requesthandler
- the handler of the WebSocket sessionMono<Void>
to indicate the outcome of the
WebSocket session handling.private void setNettyHeaders(HttpHeaders httpHeaders, io.netty.handler.codec.http.HttpHeaders nettyHeaders)
private HttpHeaders toHttpHeaders(WebsocketInbound inbound)