修正mqtt模組

models/Carpayment_model.php

@@ -865,6 +865,14 @@ class Carpayment_model extends CI_Model
     	$results = $this->db->query($sql)->result_array();
 		
         return $results;
+	}
+	
+	// 送出至message queue(目前用mqtt)
+	public function mq_send($topic, $msg)
+	{
+		$this->vars['mqtt']->publish($topic, $msg, 0);
+    	trigger_error("mqtt:{$topic}|{$msg}");
+		usleep(100000); // delay 0.1 sec (避免漏訊號)
     }
 	
 }