66
66
{stop, {network_error, Reason}, undefined}
70
stop({mqtt_unexpected_call, Msg, From}, State).
70
73
State = #state{ proc_state = PState,
71
74
conn_name = ConnName }) ->
72
75
log(warning, "MQTT disconnecting duplicate client id ~p (~p)~n",
73
76
[rabbit_mqtt_processor:info(client_id, PState), ConnName]),
74
77
stop({shutdown, duplicate_id}, State);
77
stop({mqtt_unexpected_call, Msg, From}, State).
79
79
handle_cast(Msg, State) ->
80
80
stop({mqtt_unexpected_cast, Msg}, State).