Package org.apache.qpid.protonj2.client.transport.netty5

Class WebSocketTransport

java.lang.Object

org.apache.qpid.protonj2.client.transport.netty5.TcpTransport

org.apache.qpid.protonj2.client.transport.netty5.WebSocketTransport

All Implemented Interfaces:

Transport

public class WebSocketTransport
extends TcpTransport

Netty based WebSockets Transport that wraps and extends the TCP Transport.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.protonj2.client.transport.netty5.TcpTransport

TcpTransport.NettyDefaultHandler<E>, TcpTransport.NettyTcpTransportHandler

Field Summary

Fields inherited from class org.apache.qpid.protonj2.client.transport.netty5.TcpTransport

bootstrap, channel, closed, connected, connectedLatch, failureCause, host, listener, nettyAllocator, options, port, sslOptions

Constructor Summary

Constructors

Constructor	Description
WebSocketTransport(io.netty5.bootstrap.Bootstrap bootstrap, TransportOptions options, SslOptions sslOptions)	Create a new WebSocketTransport instance with the given configuration.

Method Summary

Modifier and Type	Method	Description
protected void	addAdditionalHandlers(io.netty5.channel.ChannelPipeline pipeline)
protected io.netty5.channel.ChannelHandler	createChannelHandler()
URI	getRemoteURI()	Returns a URI that contains some meaningful information about the remote connection such as a scheme that reflects the transport type and the remote host and port that the connection was instructed to connect to.
protected String	getScheme()
protected void	handleConnected(io.netty5.channel.Channel channel)

Methods inherited from class org.apache.qpid.protonj2.client.transport.netty5.TcpTransport

awaitConnect, checkConnected, close, connect, flush, getBufferAllocator, getHost, getLocalPrincipal, getPort, getSslOptions, getTransportListener, getTransportOptions, handleTransportFailure, isConnected, isSecure, write, write, writeAndFlush, writeAndFlush

Methods inherited from class java.lang.Object

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

Constructor Details

WebSocketTransport

public WebSocketTransport(io.netty5.bootstrap.Bootstrap bootstrap,
 TransportOptions options,
 SslOptions sslOptions)

Create a new WebSocketTransport instance with the given configuration.

Parameters:

bootstrap - the Bootstrap that this transport's IO is bound to.

options - the TransportOptions used to configure the socket connection.

sslOptions - the SslOptions to use if the options indicate SSL is enabled.

Method Details

getRemoteURI

public URI getRemoteURI()

Description copied from interface: Transport

Returns a URI that contains some meaningful information about the remote connection such as a scheme that reflects the transport type and the remote host and port that the connection was instructed to connect to. If called before the Transport.connect(String, int, TransportListener) method this method returns null.

Specified by:

getRemoteURI in interface Transport

Overrides:

getRemoteURI in class TcpTransport

Returns:

a URI that reflects a meaningful view of the Transport remote connection details.

createChannelHandler

protected io.netty5.channel.ChannelHandler createChannelHandler()

Overrides:

createChannelHandler in class TcpTransport

addAdditionalHandlers

protected void addAdditionalHandlers(io.netty5.channel.ChannelPipeline pipeline)

Overrides:

addAdditionalHandlers in class TcpTransport

handleConnected

protected void handleConnected(io.netty5.channel.Channel channel)
                        throws Exception

Overrides:

handleConnected in class TcpTransport

Throws:

Exception

getScheme

protected String getScheme()

Overrides:

getScheme in class TcpTransport