diff --git a/apps/iot/src/consumer/iot_zd_consumer.erl b/apps/iot/src/consumer/iot_zd_consumer.erl index 5a05c02..d4d99e1 100644 --- a/apps/iot/src/consumer/iot_zd_consumer.erl +++ b/apps/iot/src/consumer/iot_zd_consumer.erl @@ -234,7 +234,8 @@ publish_directive(#{<<"version">> := Version, <<"location_code">> := LocationCod _ -> ReceiverPid ! {directive_reply, {error, RawReq, <<"location_code: ", LocationCode/binary, " not found in redis">>}} end; -publish_directive(_Other, RawReq) -> +publish_directive(Other, RawReq) -> + lager:warning("[iot_zd_consumer] get a error message: ~p", [Other]), self() ! {directive_reply, {error, RawReq, <<"unknown directive">>}}. -spec create_consumer(Props :: list()) -> {ok, ConnPid :: pid()} | {error, Reason :: any()}.