Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	ClientFilter.JdkWriter

Field Summary

Modifier and Type	Field and Description
private final ClientEngine	clientEngine
private volatile CompletionHandler<Void>	connectCompletionHandler
private volatile boolean	connectedToProxy
private final AtomicBoolean	connectionClosed
private final Callable<Void>	jdkConnector
private static final Logger	LOGGER
private volatile boolean	proxy
private final Map<String, String>	proxyHeaders
private final HttpResponseParser	responseParser
private final UpgradeRequest	upgradeRequest
private volatile Connection	wsConnection

Inherited from org.glassfish.tyrus.container.jdk.client.Filter:: downstreamFilter upstreamFilter

Constructor Summary

Access	Constructor and Description
pack-priv	ClientFilter(Filter a filer that is positioned directly under this filter. downstreamFilter, ClientEngine client engine instance. clientEngine, Map<String, Object> client properties. properties, Callable<Void> callback to connecting with modified `UpgradeRequest` if necessary. jdkConnector, UpgradeRequest upgrade request to be used for this client session. upgradeRequest) Constructor.

Method Summary

Modifier and Type	Method and Description
pack-priv void	close() Overrides org.glassfish.tyrus.container.jdk.client.Filter.close. Close the filter, invokes close operation on the next filter in the filter chain.
private void	closeConnection()
pack-priv void	connect(SocketAddress an address where to connect (server or proxy). address, boolean `true` if the connection will be established via proxy, `false` otherwise. proxy, CompletionHandler<Void> completion handler. connectCompletionHandler)
private JdkUpgradeRequest	createHandshakeUpgradeRequest(final UpgradeRequest upgradeRequest)
private JdkUpgradeRequest	createProxyUpgradeRequest(final URI uri)
private JdkUpgradeRequest	getJdkUpgradeRequest(final UpgradeRequest upgradeRequest, final Filter downstreamFilter)
private static Map<String, String>	getProxyHeaders(Map<String, Object> properties)
public void	processConnect() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnect. Process `onConnect()`.
public void	processConnectionClosed() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnectionClosed. Process `onConnectionClosed()`.
pack-priv void	processError(Throwable an error that has occurred. t) Overrides org.glassfish.tyrus.container.jdk.client.Filter.processError. Process `onError(Throwable)`.
public boolean	processRead(ByteBuffer read data. data) Overrides org.glassfish.tyrus.container.jdk.client.Filter.processRead. Process `onRead(ByteBuffer)`.
pack-priv void	processSslHandshakeCompleted() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processSslHandshakeCompleted. Process `onSslHandshakeCompleted()`.
private void	sendRequest(final Filter downstreamFilter, JdkUpgradeRequest handshakeUpgradeRequest)

Inherited from org.glassfish.tyrus.container.jdk.client.Filter:: connect handleConnect onConnect onConnectionClosed onError onRead onSslHandshakeCompleted startSsl write

Field Detail

clientEngine	back to summary
private final ClientEngine clientEngine

connectCompletionHandler	back to summary
private volatile CompletionHandler<Void> connectCompletionHandler

connectedToProxy	back to summary
private volatile boolean connectedToProxy

connectionClosed	back to summary
private final AtomicBoolean connectionClosed

jdkConnector	back to summary
private final Callable<Void> jdkConnector

LOGGER	back to summary
private static final Logger LOGGER

proxy	back to summary
private volatile boolean proxy

proxyHeaders	back to summary
private final Map<String, String> proxyHeaders

responseParser	back to summary
private final HttpResponseParser responseParser

upgradeRequest	back to summary
private final UpgradeRequest upgradeRequest

wsConnection	back to summary
private volatile Connection wsConnection

Constructor Detail

ClientFilter back to summary

ClientFilter	back to summary
pack-priv ClientFilter(Filter downstreamFilter, ClientEngine clientEngine, Map<String, Object> properties, Callable<Void> jdkConnector, UpgradeRequest upgradeRequest) throws DeploymentException Constructor. Parameters downstreamFilter:Filter a filer that is positioned directly under this filter. clientEngine:ClientEngine client engine instance. properties:Map<String, Object> client properties. jdkConnector:Callable<Void> callback to connecting with modified `UpgradeRequest` if necessary. upgradeRequest:UpgradeRequest upgrade request to be used for this client session.

pack-priv ClientFilter(Filter downstreamFilter, ClientEngine clientEngine, Map<String, Object> properties, Callable<Void> jdkConnector, UpgradeRequest upgradeRequest) throws DeploymentException

Constructor.

Parameters

downstreamFilter:Filter: a filer that is positioned directly under this filter.
clientEngine:ClientEngine: client engine instance.
properties:Map<String, Object>: client properties.
jdkConnector:Callable<Void>: callback to connecting with modified UpgradeRequest if necessary.
upgradeRequest:UpgradeRequest: upgrade request to be used for this client session.

Method Detail

close	back to summary
pack-priv void close() Overrides org.glassfish.tyrus.container.jdk.client.Filter.close. Doc from org.glassfish.tyrus.container.jdk.client.Filter.close. Close the filter, invokes close operation on the next filter in the filter chain. The filter is expected to clean up any allocated resources and pass the invocation to downstream filter. Annotations @Override

back to summary

pack-priv void close()

Overrides org.glassfish.tyrus.container.jdk.client.Filter.close.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.close.

Close the filter, invokes close operation on the next filter in the filter chain.

The filter is expected to clean up any allocated resources and pass the invocation to downstream filter.

Annotations

@Override

closeConnection	back to summary
private void closeConnection()

connect	back to summary
pack-priv void connect(SocketAddress address, boolean proxy, CompletionHandler<Void> connectCompletionHandler) Parameters address:SocketAddress an address where to connect (server or proxy). proxy:boolean `true` if the connection will be established via proxy, `false` otherwise. connectCompletionHandler:CompletionHandler<Void> completion handler.

createHandshakeUpgradeRequest	back to summary
private JdkUpgradeRequest createHandshakeUpgradeRequest(final UpgradeRequest upgradeRequest)

createProxyUpgradeRequest	back to summary
private JdkUpgradeRequest createProxyUpgradeRequest(final URI uri)

getJdkUpgradeRequest	back to summary
private JdkUpgradeRequest getJdkUpgradeRequest(final UpgradeRequest upgradeRequest, final Filter downstreamFilter)

getProxyHeaders	back to summary
private static Map<String, String> getProxyHeaders(Map<String, Object> properties) throws DeploymentException

processConnect back to summary

processConnect	back to summary
public void processConnect() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnect. Doc from org.glassfish.tyrus.container.jdk.client.Filter.processConnect. Process `onConnect()`. Annotations @Override

public void processConnect()

Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnect.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.processConnect.

Process onConnect().

Annotations

@Override

processConnectionClosed back to summary

processConnectionClosed	back to summary
public void processConnectionClosed() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnectionClosed. Doc from org.glassfish.tyrus.container.jdk.client.Filter.processConnectionClosed. Process `onConnectionClosed()`. Annotations @Override

public void processConnectionClosed()

Overrides org.glassfish.tyrus.container.jdk.client.Filter.processConnectionClosed.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.processConnectionClosed.

Process onConnectionClosed().

Annotations

@Override

processError back to summary

processError	back to summary
pack-priv void processError(Throwable t) Overrides org.glassfish.tyrus.container.jdk.client.Filter.processError. Doc from org.glassfish.tyrus.container.jdk.client.Filter.processError. Process `onError(Throwable)`. Parameters t:Throwable an error that has occurred. Annotations @Override

pack-priv void processError(Throwable t)

Overrides org.glassfish.tyrus.container.jdk.client.Filter.processError.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.processError.

Process onError(Throwable).

Parameters

t:Throwable: an error that has occurred.

Annotations

@Override

processRead back to summary

processRead	back to summary
public boolean processRead(ByteBuffer data) Overrides org.glassfish.tyrus.container.jdk.client.Filter.processRead. Doc from org.glassfish.tyrus.container.jdk.client.Filter.processRead. Process `onRead(ByteBuffer)`. Parameters data:ByteBuffer read data. Returns:boolean `true` if the data should be sent to processing to upper filter in the chain, `false` otherwise. Annotations @Override

public boolean processRead(ByteBuffer data)

Overrides org.glassfish.tyrus.container.jdk.client.Filter.processRead.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.processRead.

Process onRead(ByteBuffer).

Parameters

data:ByteBuffer: read data.

Returns:boolean

true if the data should be sent to processing to upper filter in the chain, false otherwise.

Annotations

@Override

processSslHandshakeCompleted back to summary

processSslHandshakeCompleted	back to summary
pack-priv void processSslHandshakeCompleted() Overrides org.glassfish.tyrus.container.jdk.client.Filter.processSslHandshakeCompleted. Doc from org.glassfish.tyrus.container.jdk.client.Filter.processSslHandshakeCompleted. Process `onSslHandshakeCompleted()`. Annotations @Override

pack-priv void processSslHandshakeCompleted()

Overrides org.glassfish.tyrus.container.jdk.client.Filter.processSslHandshakeCompleted.

Doc from org.glassfish.tyrus.container.jdk.client.Filter.processSslHandshakeCompleted.

Process onSslHandshakeCompleted().

Annotations

@Override

sendRequest	back to summary
private void sendRequest(final Filter downstreamFilter, JdkUpgradeRequest handshakeUpgradeRequest)

org.glassfish.tyrus.container.jdk.client back to summary

private Class ClientFilter.JdkWriter

Class Inheritance

extends Writer

java.lang.Object
org.glassfish.tyrus.spi.Writer
org.glassfish.tyrus.container.jdk.client.ClientFilter.JdkWriter

Field Summary

Modifier and Type	Field and Description
private final AtomicBoolean	connectionClosed
private final Filter	downstreamFilter

Constructor Summary

Access	Constructor and Description
pack-priv	JdkWriter(Filter downstreamFilter, AtomicBoolean connectionClosed)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
public void	write(ByteBuffer bytes to write. buffer, CompletionHandler<ByteBuffer> completion handler to know the write status. completionHandler) Implements abstract org.glassfish.tyrus.spi.Writer.write. A backward compatible method called from `write(ByteBuffer, CompletionHandler, WriterInfo)` to handover the data for a connection to the transport.

Inherited from org.glassfish.tyrus.spi.Writer:: write

Field Detail

connectionClosed	back to summary
private final AtomicBoolean connectionClosed

downstreamFilter	back to summary
private final Filter downstreamFilter

Constructor Detail

JdkWriter	back to summary
pack-priv JdkWriter(Filter downstreamFilter, AtomicBoolean connectionClosed)

Method Detail

close back to summary

close	back to summary
public void close() throws IOException Implements java.io.Closeable.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Annotations @Override Exceptions IOException: if an I/O error occurs

public void close() throws IOException

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs

write back to summary

write	back to summary
public void write(ByteBuffer buffer, CompletionHandler<ByteBuffer> completionHandler) Implements abstract org.glassfish.tyrus.spi.Writer.write. Doc from org.glassfish.tyrus.spi.Writer.write. A backward compatible method called from `write(ByteBuffer, CompletionHandler, WriterInfo)` to handover the data for a connection to the transport. The transport writes bytes to underlying connection. Tyrus runtime must not use the buffer until the write is completed. The method will be removed in the next major version. Parameters buffer:ByteBuffer bytes to write. completionHandler:CompletionHandler<ByteBuffer> completion handler to know the write status. Annotations @Override

public void write(ByteBuffer buffer, CompletionHandler<ByteBuffer> completionHandler)

Implements abstract org.glassfish.tyrus.spi.Writer.write.

Doc from org.glassfish.tyrus.spi.Writer.write.

A backward compatible method called from write(ByteBuffer, CompletionHandler, WriterInfo) to handover the data for a connection to the transport. The transport writes bytes to underlying connection. Tyrus runtime must not use the buffer until the write is completed.

The method will be removed in the next major version.

Parameters

buffer:ByteBuffer: bytes to write.
completionHandler:CompletionHandler<ByteBuffer>: completion handler to know the write status.

Annotations

@Override

pack-priv Class ClientFilter

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ClientFilter.JdkWriter

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail