return $ns;
}
+
+ function isFirstServer()
+ {
+ $servers = $this->availableServers();
+ if (empty($servers)) {
+ return false;
+ }
+ // only run this on the first server...
+ return $this->id == $servers[0]->id;
+ }
+
+
// called on current server.
function assignQueues($notify)
{