org.springframework.web.socket.server.standard

Class UndertowRequestUpgradeStrategy

java.lang.Object

org.springframework.web.socket.server.standard.AbstractStandardUpgradeStrategy

org.springframework.web.socket.server.standard.UndertowRequestUpgradeStrategy

All Implemented Interfaces:

RequestUpgradeStrategy

public class UndertowRequestUpgradeStrategy
extends AbstractStandardUpgradeStrategy

A WebSocket RequestUpgradeStrategy for use with WildFly and its underlying Undertow web server. Also compatible with embedded Undertow usage.

Compatible with Undertow 1.0 to 1.3 - as included in WildFly 8.x, 9 and 10.

Since:

4.0.1

Author:

Rossen Stoyanchev, Brian Clozel, Juergen Hoeller

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	UndertowRequestUpgradeStrategy.EndpointInstanceFactory

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.reflect.Method	createChannelMethod
private static java.lang.reflect.Constructor<ConfiguredServerEndpoint>	endpointConstructor
private static boolean	endpointConstructorWithEndpointFactory
private static java.lang.reflect.Constructor<ServletWebSocketHttpExchange>	exchangeConstructor
private static boolean	exchangeConstructorWithPeerConnections
private static java.lang.reflect.Method	getBufferPoolMethod
private java.util.Set<WebSocketChannel>	peerConnections
private static java.lang.String[]	supportedVersions

Fields inherited from class org.springframework.web.socket.server.standard.AbstractStandardUpgradeStrategy

logger

Constructor Summary

Constructors

Constructor and Description
UndertowRequestUpgradeStrategy()

Method Summary

Modifier and Type	Method and Description
private ConfiguredServerEndpoint	createConfiguredServerEndpoint(java.lang.String selectedProtocol, java.util.List<Extension> selectedExtensions, Endpoint endpoint, HttpServletRequest servletRequest)
private ServletWebSocketHttpExchange	createHttpExchange(HttpServletRequest request, HttpServletResponse response)
private Handshake	getHandshakeToUse(ServletWebSocketHttpExchange exchange, ConfiguredServerEndpoint endpoint)
java.lang.String[]	getSupportedVersions() Return the supported WebSocket protocol versions.
protected void	upgradeInternal(ServerHttpRequest request, ServerHttpResponse response, java.lang.String selectedProtocol, java.util.List<Extension> selectedExtensions, Endpoint endpoint)

Methods inherited from class org.springframework.web.socket.server.standard.AbstractStandardUpgradeStrategy

getContainer, getHttpServletRequest, getHttpServletResponse, getInstalledExtensions, getSupportedExtensions, upgrade

Methods inherited from class java.lang.Object

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

Field Detail

exchangeConstructor

private static final java.lang.reflect.Constructor<ServletWebSocketHttpExchange> exchangeConstructor

exchangeConstructorWithPeerConnections

private static final boolean exchangeConstructorWithPeerConnections

endpointConstructor

private static final java.lang.reflect.Constructor<ConfiguredServerEndpoint> endpointConstructor

endpointConstructorWithEndpointFactory

private static final boolean endpointConstructorWithEndpointFactory

getBufferPoolMethod

private static final java.lang.reflect.Method getBufferPoolMethod

createChannelMethod

private static final java.lang.reflect.Method createChannelMethod

supportedVersions

private static final java.lang.String[] supportedVersions

peerConnections

private final java.util.Set<WebSocketChannel> peerConnections

Constructor Detail

UndertowRequestUpgradeStrategy

public UndertowRequestUpgradeStrategy()

Method Detail

getSupportedVersions

public java.lang.String[] getSupportedVersions()

Description copied from interface: RequestUpgradeStrategy

Return the supported WebSocket protocol versions.

upgradeInternal

protected void upgradeInternal(ServerHttpRequest request,
                               ServerHttpResponse response,
                               java.lang.String selectedProtocol,
                               java.util.List<Extension> selectedExtensions,
                               Endpoint endpoint)
                        throws HandshakeFailureException

Specified by:

upgradeInternal in class AbstractStandardUpgradeStrategy

Throws:

HandshakeFailureException

createHttpExchange

private ServletWebSocketHttpExchange createHttpExchange(HttpServletRequest request,
                                                        HttpServletResponse response)

getHandshakeToUse

private Handshake getHandshakeToUse(ServletWebSocketHttpExchange exchange,
                                    ConfiguredServerEndpoint endpoint)

createConfiguredServerEndpoint

private ConfiguredServerEndpoint createConfiguredServerEndpoint(java.lang.String selectedProtocol,
                                                                java.util.List<Extension> selectedExtensions,
                                                                Endpoint endpoint,
                                                                HttpServletRequest servletRequest)