Package io.quarkus.websockets.next.runtime

Class WebSocketConnectorBase<THIS extends WebSocketConnectorBase<THIS>>

java.lang.Object

io.quarkus.websockets.next.runtime.WebSocketConnectorBase<THIS>

Direct Known Subclasses:

BasicWebSocketConnectorImpl, WebSocketConnectorImpl

abstract class WebSocketConnectorBase<THIS extends WebSocketConnectorBase<THIS>>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final record	WebSocketConnectorBase.WebSocketOpen

Field Summary

Fields

Modifier and Type	Field	Description
protected URI	baseUri
protected final Codecs	codecs
protected final WebSocketsClientRuntimeConfig	config
protected final ClientConnectionManager	connectionManager
protected io.vertx.core.http.WebSocketClientOptions	customWebSocketClientOptions
protected io.vertx.core.http.WebSocketConnectOptions	customWebSocketConnectOptions
protected final Map<String,List<String>>	headers
protected String	path
protected static final Pattern	PATH_PARAM_PATTERN
protected Set<String>	pathParamNames
protected final Map<String,String>	pathParams
protected final Set<String>	subprotocols
protected String	tlsConfigurationName
protected final io.quarkus.tls.TlsConfigurationRegistry	tlsConfigurationRegistry
protected final Map<String,Object>	userData
protected final io.vertx.core.Vertx	vertx

Constructor Summary

Constructors

Constructor	Description
WebSocketConnectorBase(io.vertx.core.Vertx vertx, Codecs codecs, ClientConnectionManager connectionManager, WebSocketsClientRuntimeConfig config, io.quarkus.tls.TlsConfigurationRegistry tlsConfigurationRegistry)

Method Summary

Modifier and Type	Method	Description
THIS	addHeader(String name, String value)
THIS	addSubprotocol(String value)
THIS	baseUri(URI baseUri)
THIS	customizeOptions(BiConsumer<io.vertx.core.http.WebSocketConnectOptions,io.vertx.core.http.WebSocketClientOptions> customizer)
(package private) Set<String>	getPathParamNames(String path)
protected boolean	isNotSecure(URI uri)
protected boolean	isSecure(URI uri)
(package private) Consumer<WebSocketClientConnection>	newCleanupConsumer(io.vertx.core.http.WebSocketClient client, io.vertx.core.impl.ContextImpl context)
protected io.vertx.core.http.WebSocketConnectOptions	newConnectOptions(URI serverEndpointUri)
THIS	pathParam(String name, String value)
protected io.vertx.core.http.WebSocketClientOptions	populateClientOptions()
(package private) String	replacePathParameters(String path)
protected THIS	self()
(package private) void	setPath(String path)
THIS	tlsConfigurationName(String tlsConfigurationName)
<VALUE> THIS	userData(UserData.TypedKey<VALUE> key, VALUE value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PATH_PARAM_PATTERN

protected static final Pattern PATH_PARAM_PATTERN

baseUri

protected URI baseUri

customWebSocketConnectOptions

protected io.vertx.core.http.WebSocketConnectOptions customWebSocketConnectOptions

customWebSocketClientOptions

protected io.vertx.core.http.WebSocketClientOptions customWebSocketClientOptions

pathParams

protected final Map<String,String> pathParams

headers

protected final Map<String,List<String>> headers

subprotocols

protected final Set<String> subprotocols

path

protected String path

pathParamNames

protected Set<String> pathParamNames

userData

protected final Map<String,Object> userData

tlsConfigurationName

protected String tlsConfigurationName

vertx

protected final io.vertx.core.Vertx vertx

codecs

protected final Codecs codecs

connectionManager

protected final ClientConnectionManager connectionManager

config

protected final WebSocketsClientRuntimeConfig config

tlsConfigurationRegistry

protected final io.quarkus.tls.TlsConfigurationRegistry tlsConfigurationRegistry

Constructor Details

WebSocketConnectorBase

WebSocketConnectorBase(io.vertx.core.Vertx vertx,
 Codecs codecs,
 ClientConnectionManager connectionManager,
 WebSocketsClientRuntimeConfig config,
 io.quarkus.tls.TlsConfigurationRegistry tlsConfigurationRegistry)

Method Details

baseUri

public THIS baseUri(URI baseUri)

tlsConfigurationName

public THIS tlsConfigurationName(String tlsConfigurationName)

addHeader

public THIS addHeader(String name,
 String value)

pathParam

public THIS pathParam(String name,
 String value)

addSubprotocol

public THIS addSubprotocol(String value)

userData

public <VALUE> THIS userData(UserData.TypedKey<VALUE> key,
 VALUE value)

setPath

void setPath(String path)

self

protected THIS self()

getPathParamNames

Set<String> getPathParamNames(String path)

replacePathParameters

String replacePathParameters(String path)

populateClientOptions

protected io.vertx.core.http.WebSocketClientOptions populateClientOptions()

newConnectOptions

protected io.vertx.core.http.WebSocketConnectOptions newConnectOptions(URI serverEndpointUri)

isNotSecure

protected boolean isNotSecure(URI uri)

isSecure

protected boolean isSecure(URI uri)

newCleanupConsumer

Consumer<WebSocketClientConnection> newCleanupConsumer(io.vertx.core.http.WebSocketClient client,
 io.vertx.core.impl.ContextImpl context)

customizeOptions

public THIS customizeOptions(BiConsumer<io.vertx.core.http.WebSocketConnectOptions,io.vertx.core.http.WebSocketClientOptions> customizer)