|
|
@@ -22,9 +22,9 @@
|
|
|
|
|
|
-define(LICENSE_MESSAGE, "Licensed under the Apache License, Version 2.0").
|
|
|
|
|
|
--define(PROTOCOL_VERSION, "MQTT/3.1.1").
|
|
|
+-define(PROTOCOL_VERSION, "MQTT/5.0").
|
|
|
|
|
|
--define(ERTS_MINIMUM, "7.0").
|
|
|
+-define(ERTS_MINIMUM, "8.0").
|
|
|
|
|
|
%%--------------------------------------------------------------------
|
|
|
%% Sys/Queue/Share Topics' Prefix
|
|
|
@@ -42,7 +42,7 @@
|
|
|
|
|
|
-type(pubsub() :: publish | subscribe).
|
|
|
|
|
|
--define(PUBSUB(PS), (PS =:= publish orelse PS =:= subscribe)).
|
|
|
+-define(PS(PS), (PS =:= publish orelse PS =:= subscribe)).
|
|
|
|
|
|
%%--------------------------------------------------------------------
|
|
|
%% MQTT Topic
|
|
|
@@ -172,7 +172,7 @@
|
|
|
severity :: warning | error | critical,
|
|
|
title :: iolist() | binary(),
|
|
|
summary :: iolist() | binary(),
|
|
|
- timestamp :: erlang:timestamp() %% Timestamp
|
|
|
+ timestamp :: erlang:timestamp()
|
|
|
}).
|
|
|
|
|
|
-type(mqtt_alarm() :: #mqtt_alarm{}).
|
|
|
@@ -186,8 +186,7 @@
|
|
|
-type(mqtt_plugin() :: #mqtt_plugin{}).
|
|
|
|
|
|
%%--------------------------------------------------------------------
|
|
|
-%% MQTT CLI Command
|
|
|
-%% For example: 'broker metrics'
|
|
|
+%% MQTT CLI Command. For example: 'broker metrics'
|
|
|
%%--------------------------------------------------------------------
|
|
|
|
|
|
-record(mqtt_cli, { name, action, args = [], opts = [], usage, descr }).
|