- saas patch #1

airtime_mvc/application/models/RabbitMq.php

@@ -71,4 +71,46 @@ class Application_Model_RabbitMq
 
         self::sendMessage($exchange, $data);
     }
+    
+    public static function SendMessageToHaproxyConfigDaemon($md){
+        $config = parse_ini_file("/etc/airtime-saas/rabbitmq.ini", true);
+        $conn = new AMQPConnection($config["rabbitmq"]["host"],
+        $config["rabbitmq"]["port"],
+        $config["rabbitmq"]["user"],
+        $config["rabbitmq"]["password"],
+        $config["rabbitmq"]["vhost"]);
+
+        $exchange = $config["rabbitmq"]["queue"];
+        $queue = $config["rabbitmq"]["queue"];
+
+        $ch = $conn->channel();
+
+
+        /*
+            name: $queue
+            passive: false
+            durable: true // the queue will survive server restarts
+            exclusive: false // the queue can be accessed in other channels
+            auto_delete: false //the queue won't be deleted once the channel is closed.
+        */
+        $ch->queue_declare($queue, false, true, false, false);
+
+        /*
+            name: $exchange
+            type: direct
+            passive: false
+            durable: true // the exchange will survive server restarts
+            auto_delete: false //the exchange won't be deleted once the channel is closed.
+        */
+
+        $ch->exchange_declare($exchange, 'direct', false, true, false);
+        $ch->queue_bind($queue, $exchange);
+
+        $data = json_encode($md).PHP_EOL;
+        $msg = new AMQPMessage($data, array('content_type' => 'application/json'));
+
+        $ch->basic_publish($msg, $exchange);
+        $ch->close();
+        $conn->close();
+    }        
 }