diff --git a/bin/server.js b/bin/server.js index e0a295f..485f2ca 100755 --- a/bin/server.js +++ b/bin/server.js @@ -109,6 +109,7 @@ const onconnection = conn => { if (message.topic) { const receivers = topics.get(message.topic) if (receivers) { + message.clients = receivers.size receivers.forEach(receiver => send(receiver, message) )