diff --git a/lib/serf/client.js b/lib/serf/client.js index 8c10653..b005eeb 100644 --- a/lib/serf/client.js +++ b/lib/serf/client.js @@ -84,7 +84,7 @@ Client.prototype = { var name = member.Name; if (members.some(function(member) { - return member.Tags["have-unprocessed-messages-for-" + name] == "true"; + return member.Tags["buffered-for-" + name] == "true"; })) return false;