Use Cowboy's new direct data delivery for HTTP/2 Websocket

Uses the latest Cowboy and Cowlib.

Author: lhoguin

deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl

@@ -84,7 +84,7 @@ init(Req, Opts) ->
                                    stats_timer = rabbit_event:init_stats_timer()},
                     WsOpts0 = proplists:get_value(ws_opts, Opts, #{}),
                     WsOpts  = maps:merge(#{compress => true}, WsOpts0),
-                    {?MODULE, Req1, State, WsOpts}
+                    {?MODULE, Req1, State, WsOpts#{data_delivery => relay}}
             end
     end.
 

deps/rabbitmq_web_stomp/src/rabbit_web_stomp_handler.erl

@@ -95,7 +95,7 @@ init(Req0, Opts) ->
         socket             = SockInfo,
         peername           = PeerAddr,
         auth_hd            = cowboy_req:header(<<"authorization">>, Req)
-    }, WsOpts}.
+    }, WsOpts#{data_delivery => relay}}.
 
 websocket_init(State) ->
     process_flag(trap_exit, true),

rabbitmq-components.mk

@@ -40,8 +40,8 @@ endif
 # all projects use the same versions. It avoids conflicts.
 
 dep_accept = hex 0.3.5
-dep_cowboy = hex 2.13.0
-dep_cowlib = hex 2.14.0
+dep_cowboy = git https://github.com/ninenines/cowboy direct-data_delivery-for-h2-websocket
+dep_cowlib = git https://github.com/ninenines/cowlib master
 dep_credentials_obfuscation = hex 3.5.0
 dep_cuttlefish = hex 3.5.0
 dep_gen_batch_server = hex 0.8.8