DataObjects/Core_notify_server.php

diff --git a/DataObjects/Core_notify_server.php b/DataObjects/Core_notify_server.php
index b66e89c..655c1e5 100644 (file)
--- a/DataObjects/Core_notify_server.php
+++ b/DataObjects/Core_notify_server.php
@@ -39,6 +39,18 @@ class Pman_Core_DataObjects_Core_notify_server extends DB_DataObject
         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)
     {