From 4701d1f55e752df79df33817fce2d4c1a989d387 Mon Sep 17 00:00:00 2001
From: Stuart Douglas <stuart.w.douglas@gmail.com>
Date: Thu, 1 Apr 2021 12:44:39 +1100
Subject: [PATCH] Disable extensions for now

---
 .../websockets/vertx/VertxWebSocketHttpExchange.java      | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/websocket/vertx/src/main/java/io/undertow/websockets/vertx/VertxWebSocketHttpExchange.java b/websocket/vertx/src/main/java/io/undertow/websockets/vertx/VertxWebSocketHttpExchange.java
index 7c2e34370..5a34b53cd 100644
--- a/websocket/vertx/src/main/java/io/undertow/websockets/vertx/VertxWebSocketHttpExchange.java
+++ b/websocket/vertx/src/main/java/io/undertow/websockets/vertx/VertxWebSocketHttpExchange.java
@@ -15,6 +15,7 @@
 
 package io.undertow.websockets.vertx;
 
+import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.http.HttpHeaderNames;
 import io.undertow.websockets.handshake.WebSocketHttpExchange;
@@ -114,6 +115,13 @@ public void setResponseHeader(final CharSequence headerName, final String header
     @Override
     public void upgradeChannel(Consumer<Object> listener) {
         response.headers().set(HttpHeaderNames.CONNECTION, "upgrade");
+
+        Http1xServerConnection connection = (Http1xServerConnection) request.connection();
+        ChannelHandlerContext context = connection.channelHandlerContext();
+        final ChannelHandler websocketChannelHandler = context.pipeline().get("websocketExtensionHandler");
+        if (websocketChannelHandler != null) {
+            context.pipeline().remove(websocketChannelHandler);
+        }
         response.setStatusCode(101).end(new Handler<AsyncResult<Void>>() {
             @Override
             public void handle(AsyncResult<Void> event) {