From d397ae7da1bd9a8a6c6c2894457f1528437a8b09 Mon Sep 17 00:00:00 2001 From: Feng Date: Mon, 30 Nov 2015 23:35:46 +0800 Subject: [PATCH 1/2] subscribe --- src/emqttd_pubsub.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 0f8d3a2c6..854298873 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -239,8 +239,8 @@ init([Id, _Opts]) -> prioritise_call(Msg, _From, _Len, _State) -> case Msg of - {subscriber, _, _} -> 1; - _ -> 0 + {subscribe, _, _} -> 1; + _ -> 0 end. prioritise_cast(Msg, _Len, _State) -> From 60c5baa8036cf7eb6f5beaa5fae9cca3b2a4dc24 Mon Sep 17 00:00:00 2001 From: Kevin Smith Date: Tue, 1 Dec 2015 16:15:35 -0500 Subject: [PATCH 2/2] Add runtime deps on gproc and esockd --- src/emqttd.app.src | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/emqttd.app.src b/src/emqttd.app.src index 4e77ea1bb..9a6abc4ce 100644 --- a/src/emqttd.app.src +++ b/src/emqttd.app.src @@ -6,7 +6,9 @@ {modules, []}, {registered, []}, {applications, [kernel, - stdlib]}, + stdlib, + gproc, + esockd]}, {mod, {emqttd_app, []}}, {env, []} ]}.