@@ -115,7 +115,7 @@ websocket_info({'EXIT', _, _}, State) ->
115
115
{stop , State };
116
116
websocket_info ({'$gen_cast' , duplicate_id }, State = # state { proc_state = ProcState ,
117
117
conn_name = ConnName }) ->
118
- rabbit_log_connection :warning (" WEB- MQTT disconnecting duplicate client id ~p (~p )~n " ,
118
+ rabbit_log_connection :warning (" Web MQTT disconnecting duplicate client id ~p (~p )~n " ,
119
119
[rabbit_mqtt_processor :info (client_id , ProcState ), ConnName ]),
120
120
{stop , State };
121
121
websocket_info ({start_keepalives , Keepalive },
@@ -129,20 +129,20 @@ websocket_info({start_keepalives, Keepalive},
129
129
{ok , State # state { keepalive = Heartbeater }, hibernate };
130
130
websocket_info (keepalive_timeout , State = # state {conn_name = ConnStr ,
131
131
proc_state = PState }) ->
132
- rabbit_log_connection :error (" closing WEB- MQTT connection ~p (keepalive timeout)~n " , [ConnStr ]),
132
+ rabbit_log_connection :error (" closing Web MQTT connection ~p (keepalive timeout)~n " , [ConnStr ]),
133
133
rabbit_mqtt_processor :send_will (PState ),
134
134
{stop , State };
135
135
websocket_info (emit_stats , State ) ->
136
136
{ok , emit_stats (State ), hibernate };
137
137
websocket_info (Msg , State ) ->
138
- rabbit_log_connection :info (" WEB- MQTT: unexpected message ~p~n " ,
138
+ rabbit_log_connection :info (" Web MQTT: unexpected message ~p~n " ,
139
139
[Msg ]),
140
140
{ok , State , hibernate }.
141
141
142
142
terminate (_ , _ , State = # state { proc_state = ProcState ,
143
143
conn_name = ConnName }) ->
144
144
maybe_emit_stats (State ),
145
- rabbit_log_connection :info (" closing WEB- MQTT connection ~p (~s )~n " , [self (), ConnName ]),
145
+ rabbit_log_connection :info (" closing Web MQTT connection ~p (~s )~n " , [self (), ConnName ]),
146
146
rabbit_mqtt_processor :close_connection (ProcState ),
147
147
ok ;
148
148
terminate (_ , _ , State ) ->
0 commit comments