From dae81037bff0dba56a2094a7670bbc217bde2270 Mon Sep 17 00:00:00 2001
From: turtled <turtled@emqtt.io>
Date: Wed, 29 Aug 2018 12:58:55 +0800
Subject: [PATCH] Update share_sub dispatch

---
 src/emqx_shared_sub.erl | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/emqx_shared_sub.erl b/src/emqx_shared_sub.erl
index 7a70fca59..ce21a1bf8 100644
--- a/src/emqx_shared_sub.erl
+++ b/src/emqx_shared_sub.erl
@@ -93,8 +93,7 @@ pick([]) ->
 pick([SubPid]) ->
     SubPid;
 pick(SubPids) ->
-    X = abs(erlang:monotonic_time() bxor erlang:unique_integer()),
-    lists:nth((X rem length(SubPids)) + 1, SubPids).
+    lists:nth(rand:uniform(length(SubPids)), SubPids).
 
 subscribers(Group, Topic) ->
     ets:select(?TAB, [{{emqx_shared_subscription, Group, Topic, '$1'}, [], ['$1']}]).