diff --git a/src/emqttd_mqueue.erl b/src/emqttd_mqueue.erl index 385a6be39..866abee09 100644 --- a/src/emqttd_mqueue.erl +++ b/src/emqttd_mqueue.erl @@ -147,6 +147,8 @@ len(#mqueue{type = priority, q = Q}) -> priority_queue:len(Q). max_len(#mqueue{max_len= MaxLen}) -> MaxLen. +%% @doc Stats of the mqueue +-spec stats(mqueue()) -> [stat()]. stats(#mqueue{type = Type, q = Q, max_len = MaxLen, len = Len, dropped = Dropped}) -> [{len, case Type of simple -> Len;