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

Add mqueue_type, mqueue_priorities options

This commit is contained in:
Feng Lee 2018-08-30 18:26:31 +08:00
parent 8ed6266ace
commit 7b58718280
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
priv/emqx.schema
View File

@ -646,6 +646,18 @@ end}.
{datatype, {enum, [true, false]}} {datatype, {enum, [true, false]}}
]}. ]}.
%% @doc Type: simple | priority
{mapping, "mqtt.mqueue_type", "emqx.mqueue_type", [
{default, simple},
{datatype, {enum, [simple, priority]}}
]}.
%% @doc Topic Priorities: 0~255, Default is 0
{mapping, "mqtt.mqueue_priorities", "emqx.mqueue_priorities", [
{default, ""},
{datatype, string}
]}.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Zones %% Zones
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
@ -777,6 +789,12 @@ end}.
{datatype, {duration, ms}} {datatype, {duration, ms}}
]}. ]}.
%% @doc Type: simple | priority
{mapping, "zone.$name.mqueue_type", "emqx.zones", [
{default, simple},
{datatype, {enum, [simple, priority]}}
]}.
%% @doc Max queue length. Enqueued messages when persistent client %% @doc Max queue length. Enqueued messages when persistent client
%% disconnected, or inflight window is full. 0 means no limit. %% disconnected, or inflight window is full. 0 means no limit.
{mapping, "zone.$name.max_mqueue_len", "emqx.zones", [ {mapping, "zone.$name.max_mqueue_len", "emqx.zones", [
@ -784,6 +802,11 @@ end}.
{datatype, integer} {datatype, integer}
]}. ]}.
%% @doc Topic Priorities: 0~255, Default is 0
{mapping, "zone.$name.mqueue_priorities", "emqx.zones", [
{datatype, string}
]}.
%% @doc Queue Qos0 messages? %% @doc Queue Qos0 messages?
{mapping, "zone.$name.mqueue_store_qos0", "emqx.zones", [ {mapping, "zone.$name.mqueue_store_qos0", "emqx.zones", [
{default, true}, {default, true},