diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 63c4146d7..0f8d3a2c6 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -232,7 +232,7 @@ match(Topic) when is_binary(Topic) -> %%%============================================================================= init([Id, _Opts]) -> - process_flag(priority, high), + %%process_flag(priority, high), %%process_flag(min_heap_size, 1024*1024), gproc_pool:connect_worker(pubsub, {?MODULE, Id}), {ok, #state{id = Id, submap = maps:new()}}.