diff --git a/CHANGELOG.md b/CHANGELOG.md index 91b0527ec..dc03415e9 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,6 +2,18 @@ emqttd ChangeLog ================ +0.17.1-beta(2016-03-22) +------------------------ + +### Enhancements + +Time unit of session 'expired_after' changed to minute. (#479) + +### Dashboard + +Code Review and improve the design of Dashboard. + + 0.17.0-beta(2016-03-15) ------------------------ diff --git a/plugins/emqttd_dashboard b/plugins/emqttd_dashboard index c8d744eca..6254ae5ab 160000 --- a/plugins/emqttd_dashboard +++ b/plugins/emqttd_dashboard @@ -1 +1 @@ -Subproject commit c8d744ecafceae98fd570468b522f1262b7ff148 +Subproject commit 6254ae5ab42ef5479527f5e9766fcbf0d1485540 diff --git a/rel/files/emqttd.config.development b/rel/files/emqttd.config.development index c655b3c3c..32424846b 100644 --- a/rel/files/emqttd.config.development +++ b/rel/files/emqttd.config.development @@ -104,8 +104,8 @@ %% Statistics Collection Interval(seconds) {collect_interval, 20}, - %% Expired after 2 days - {expired_after, 48} + %% Expired after 2 day (unit: minute) + {expired_after, 2880} ]}, %% Queue @@ -176,11 +176,12 @@ %% Subscribe topics automatically when client connected {subscription, [ - %% Static subscriptions from backend - backend, %% $c will be replaced by clientid - {"$queue/clients/$c", 1} + %% {"$queue/clients/$c", 1}, + + %% Static subscriptions from backend + backend ]} %% Rewrite rules diff --git a/rel/files/emqttd.config.production b/rel/files/emqttd.config.production index 837238c4f..df0a0da6e 100644 --- a/rel/files/emqttd.config.production +++ b/rel/files/emqttd.config.production @@ -96,8 +96,8 @@ %% Statistics Collection Interval(seconds) {collect_interval, 0}, - %% Expired after 2 days - {expired_after, 48} + %% Expired after 2 day (unit: minute) + {expired_after, 2880} ]}, %% Queue @@ -168,11 +168,12 @@ %% Subscribe topics automatically when client connected {subscription, [ - %% Static subscriptions from backend - backend, %% $c will be replaced by clientid - {"$queue/clients/$c", 1} + %% {"$queue/clients/$c", 1}, + + %% Static subscriptions from backend + backend ]} %% Rewrite rules diff --git a/src/emqttd.app.src b/src/emqttd.app.src index 19e661993..3c0db6351 100644 --- a/src/emqttd.app.src +++ b/src/emqttd.app.src @@ -1,7 +1,7 @@ {application, emqttd, [ {description, "Erlang MQTT Broker"}, - {vsn, "0.17.0"}, + {vsn, "0.17.1"}, {id, "emqttd"}, {modules, []}, {registered, []}, diff --git a/src/emqttd_cli.erl b/src/emqttd_cli.erl index fc1f300b9..d41bf26de 100644 --- a/src/emqttd_cli.erl +++ b/src/emqttd_cli.erl @@ -40,7 +40,7 @@ stack_size, reductions]). --define(MAX_LINES, 10000). +-define(MAX_LIMIT, 10000). -define(APP, emqttd). @@ -266,7 +266,7 @@ subscriptions(_) -> if_could_print(Tab, Fun) -> case mnesia:table_info(Tab, size) of - Size when Size >= ?MAX_LINES -> + Size when Size >= ?MAX_LIMIT -> ?PRINT("Could not list, too many ~ss: ~p~n", [Tab, Size]); _Size -> Keys = mnesia:dirty_all_keys(Tab), diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index ff15e415c..ac7af465b 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -230,7 +230,7 @@ init([CleanSess, ClientId, ClientPid]) -> retry_interval = get_value(unack_retry_interval, SessEnv), await_rel_timeout = get_value(await_rel_timeout, SessEnv), max_awaiting_rel = get_value(max_awaiting_rel, SessEnv), - expired_after = get_value(expired_after, SessEnv) * 3600, + expired_after = get_value(expired_after, SessEnv) * 60, collect_interval = get_value(collect_interval, SessEnv, 0), timestamp = os:timestamp()}, emqttd_sm:register_session(CleanSess, ClientId, sess_info(Session)),