Support for GlassFish 4.1.1 (Tyrus 1.9 - 1.12)

Issue: SPR-13566

Author: jhoeller

spring-websocket/src/main/java/org/springframework/web/socket/server/standard/AbstractTyrusRequestUpgradeStrategy.java

@@ -60,6 +60,7 @@
  * <p>Works with Tyrus 1.3.5 (WebLogic 12.1.3) and Tyrus 1.7+ (GlassFish 4.1.x).
  *
  * @author Rossen Stoyanchev
+ * @author Brian Clozel
  * @since 4.1
  * @see <a href="https://tyrus.java.net/">Project Tyrus</a>
  */
@@ -181,13 +182,20 @@ protected static class Tyrus17EndpointHelper implements TyrusEndpointHelper {
 
 		private static final Constructor<?> constructor;
 
+		private static boolean constructorWithBooleanArgument;
+
 		private static final Method registerMethod;
 
 		private static final Method unRegisterMethod;
 
 		static {
 			try {
 				constructor = getEndpointConstructor();
+				int parameterCount = constructor.getParameterTypes().length;
+				constructorWithBooleanArgument = (parameterCount == 10);
+				if (!constructorWithBooleanArgument && parameterCount != 9) {
+					throw new IllegalStateException("Expected TyrusEndpointWrapper constructor with 9 or 10 arguments");
+				}
 				registerMethod = TyrusWebSocketEngine.class.getDeclaredMethod("register", TyrusEndpointWrapper.class);
 				unRegisterMethod = TyrusWebSocketEngine.class.getDeclaredMethod("unregister", TyrusEndpointWrapper.class);
 				ReflectionUtils.makeAccessible(registerMethod);
@@ -216,8 +224,14 @@ public Object createdEndpoint(ServerEndpointRegistration registration, Component
 			Object sessionListener = accessor.getPropertyValue("sessionListener");
 			Object clusterContext = accessor.getPropertyValue("clusterContext");
 			try {
-				return constructor.newInstance(registration.getEndpoint(), registration, provider, container,
-						"/",  registration.getConfigurator(), sessionListener, clusterContext, null);
+				if (constructorWithBooleanArgument) {
+					return constructor.newInstance(registration.getEndpoint(), registration, provider, container,
+							"/", registration.getConfigurator(), sessionListener, clusterContext, null, Boolean.TRUE);
+				}
+				else {
+					return constructor.newInstance(registration.getEndpoint(), registration, provider, container,
+							"/", registration.getConfigurator(), sessionListener, clusterContext, null);
+				}
 			}
 			catch (Exception ex) {
 				throw new HandshakeFailureException("Failed to register " + registration, ex);