diff --git a/src/emqx.erl b/src/emqx.erl index 475428fd4..d6437b3f5 100644 --- a/src/emqx.erl +++ b/src/emqx.erl @@ -124,10 +124,8 @@ list_to_subid(SubId) when is_list(SubId) -> iolist_to_binary(SubId); list_to_subid(SubPid) when is_pid(SubPid) -> SubPid; -list_to_subid({SubId, SubPid}) when is_binary(SubId), is_pid(SubPid) -> - {SubId, SubPid}; -list_to_subid({SubId, SubPid}) when is_list(SubId), is_pid(SubPid) -> - {iolist_to_binary(SubId), SubPid}. +list_to_subid({SubPid, SubId}) when is_pid(SubPid), is_binary(SubId) -> + {SubPid, SubId}. %%-------------------------------------------------------------------- %% Hooks API