@@ -245,16 +245,16 @@ websocket_info({start_heartbeats, {SendTimeout, ReceiveTimeout}},
245245 SendFun = fun () -> Self ! {send , <<$\n >>}, ok end ,
246246 ReceiveFun = fun () -> Self ! client_timeout end ,
247247 Heartbeat = case Sock of
248- {rabbit_proxy_socket , _ , #{http_version := 'HTTP/2' }} ->
248+ {rabbit_proxy_socket , RealSocket , #{http_version := 'HTTP/2' }} ->
249249 % % HTTP/2 Websocket may have multiple Websocket sessions
250250 % % on a single connection (this can happen for example
251251 % % when refreshing a page). As a result we need to attach
252252 % % the heartbeat processes to the session. We do this via
253253 % % a link for now. @todo In the future we will have a
254254 % % mechanism in Cowboy to attach them to the stream.
255- {ok , Sender } = rabbit_heartbeat :start_heartbeat_sender (Sock ,
255+ {ok , Sender } = rabbit_heartbeat :start_heartbeat_sender (RealSocket ,
256256 SendTimeout , SendFun , unknown ),
257- {ok , Receiver } = rabbit_heartbeat :start_heartbeat_receiver (Sock ,
257+ {ok , Receiver } = rabbit_heartbeat :start_heartbeat_receiver (RealSocket ,
258258 ReceiveTimeout , ReceiveFun , unknown ),
259259 {Sender , Receiver };
260260 _ ->
0 commit comments