Skip to content

Commit 64dea55

Browse files
author
Loïc Hoguin
committed
Web-MQTT: Fix LOCAL proxy_header test
1 parent 97b9470 commit 64dea55

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

deps/rabbitmq_web_mqtt/test/proxy_protocol_SUITE.erl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,12 @@ proxy_protocol_v2_local(Config) ->
111111
WS = rfc6455_client:new(Protocol ++ "://127.0.0.1:" ++ PortStr ++ "/ws", self(),
112112
undefined, ["mqtt"], ranch_proxy_header:header(ProxyInfo)),
113113
{ok, _} = rfc6455_client:open(WS),
114-
rfc6455_client:send_binary(WS, rabbit_ws_test_util:mqtt_3_1_1_connect_packet()),
114+
Frame = emqttc_serialiser:serialise(
115+
?CONNECT_PACKET(#mqtt_packet_connect{
116+
client_id = <<"web-mqtt-tests-proxy-protocol">>,
117+
username = <<"guest">>,
118+
password = <<"guest">>})),
119+
rfc6455_client:send_binary(WS, Frame),
115120
{binary, _P} = rfc6455_client:recv(WS),
116121
ConnectionName = rabbit_ct_broker_helpers:rpc(Config, 0,
117122
?MODULE, connection_name, []),

0 commit comments

Comments
 (0)