From 3dde1511e69f9995c507455547925244fab93d40 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Hoguin?= Date: Tue, 13 Nov 2018 14:42:46 +0100 Subject: [PATCH] Add two missing hibernate in returned tuples --- deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl b/deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl index 8c66f13b7b..4f55c1263e 100644 --- a/deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl +++ b/deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl @@ -126,14 +126,14 @@ websocket_info({start_keepalives, Keepalive}, ReceiveFun = fun() -> Parent ! keepalive_timeout end, Heartbeater = rabbit_heartbeat:start( KeepaliveSup, Sock, 0, SendFun, Keepalive, ReceiveFun), - {ok, State #state { keepalive = Heartbeater }}; + {ok, State #state { keepalive = Heartbeater }, hibernate}; websocket_info(keepalive_timeout, State = #state {conn_name = ConnStr, proc_state = PState}) -> rabbit_log_connection:error("closing WEB-MQTT connection ~p (keepalive timeout)~n", [ConnStr]), rabbit_mqtt_processor:send_will(PState), {stop, State}; websocket_info(emit_stats, State) -> - {ok, emit_stats(State)}; + {ok, emit_stats(State), hibernate}; websocket_info(Msg, State) -> rabbit_log_connection:info("WEB-MQTT: unexpected message ~p~n", [Msg]),