yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(typespec): fix type spec for emqx_shared_sub:redispatch_to

This commit is contained in:
Zaiming (Stone) Shi 2022-10-05 10:04:09 +02:00
parent 9989f4df7e
commit ba1c276c75
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_shared_sub.erl
View File

@ -85,6 +85,8 @@
-define(NO_ACK, no_ack).
-define(REDISPATCH_TO(GROUP, TOPIC), {GROUP, TOPIC}).
-type redispatch_to() :: ?REDISPATCH_TO(emqx_topic:group(), emqx_topic:topic()).
-record(state, {pmon}).
-record(emqx_shared_subscription, {group, topic, subpid}).
@ -245,7 +247,7 @@ is_redispatch_needed(Msg) ->
%% @hidden Return the `redispatch_to` group-topic in the message header.
%% `false` is returned if the message is not a shared dispatch.
%% or when it's a QoS 0 message.
-spec(get_redispatch_to(emqx_types:message()) -> emqx_types:topic() | false).
-spec(get_redispatch_to(emqx_types:message()) -> redispatch_to() | false).
get_redispatch_to(Msg) ->
emqx_message:get_header(redispatch_to, Msg, false).