|
|
@@ -651,7 +651,7 @@ init([]) ->
|
|
|
ok = emqx_tables:new(?CHAN_TAB, [bag, {read_concurrency, true} | TabOpts]),
|
|
|
ok = emqx_tables:new(?CHAN_CONN_TAB, [bag | TabOpts]),
|
|
|
ok = emqx_tables:new(?CHAN_INFO_TAB, [ordered_set, compressed | TabOpts]),
|
|
|
- ok = emqx_tables:new(?CHAN_LIVE_TAB, [set, {write_concurrency, true} | TabOpts]),
|
|
|
+ ok = emqx_tables:new(?CHAN_LIVE_TAB, [ordered_set, {write_concurrency, true} | TabOpts]),
|
|
|
ok = emqx_stats:update_interval(chan_stats, fun ?MODULE:stats_fun/0),
|
|
|
State = #{chan_pmon => emqx_pmon:new()},
|
|
|
{ok, State}.
|