Frank Feng 9 years atrás
parent
commit
7cb3b7ca8a
1 changed files with 1 additions and 1 deletions
  1. 1 1
      include/emqttd_internal.hrl

+ 1 - 1
include/emqttd_internal.hrl

@@ -19,7 +19,7 @@
 -define(GPROC_POOL(JoinOrLeave, Pool, I),
         (begin
             case JoinOrLeave of
-                join  -> gproc_pool:connect_worker(Pool, {Pool, Id});
+                join  -> gproc_pool:connect_worker(Pool, {Pool, I});
                 leave -> gproc_pool:disconnect_worker(Pool, {Pool, I})
             end
         end)).