diff --git a/include/emqttd_internal.hrl b/include/emqttd_internal.hrl index 7a4806570..8d6d4c515 100644 --- a/include/emqttd_internal.hrl +++ b/include/emqttd_internal.hrl @@ -39,3 +39,21 @@ [{K, V} || {K, V} <- ?record_to_proplist(Def, Rec), lists:member(K, Fields)]). +-define(UNEXPECTED_REQ(Req, State), + (begin + lager:error("Unexpected Request: ~p", [Req]), + {reply, {error, unexpected_request}, State} + end)). + +-define(UNEXPECTED_MSG(Msg, State), + (begin + lager:error("Unexpected Message: ~p", [Msg]), + {noreply, State} + end)). + +-define(UNEXPECTED_INFO(Info, State), + (begin + lager:error("Unexpected Info: ~p", [Info]), + {noreply, State} + end)). +