diff --git a/controllers/Carpark.php b/controllers/Carpark.php
index 2867fe6..d27a1e7 100644
--- a/controllers/Carpark.php
+++ b/controllers/Carpark.php
@@ -51,7 +51,7 @@ class Carpark extends CI_Controller
 		
 		// 資料介接模組
 		$this->load->model('sync_data_model'); 
-		$this->sync_data_model->init($this->vars);
+		$this->sync_data_model->init($this->vars);	// for memcache
 		
 		// mqtt subscribe
 		$station_setting = $this->sync_data_model->station_setting_query();
@@ -60,6 +60,9 @@ class Carpark extends CI_Controller
 		$this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid());
 		$this->vars['mqtt']->connect();
 		
+		// init again
+		$this->sync_data_model->init($this->vars);	// for mqtt
+		
 		// 產生 excel 報表
 		$this->load->model('excel_model'); 
         $this->excel_model->init($this->vars);
diff --git a/controllers/Cars.php b/controllers/Cars.php
index 7c4f9a6..95aec30 100644
--- a/controllers/Cars.php
+++ b/controllers/Cars.php
@@ -98,7 +98,7 @@ class Cars extends CI_Controller
 		
 		// 資料介接模組
 		$this->load->model('sync_data_model'); 
-		$this->sync_data_model->init($this->vars);
+		$this->sync_data_model->init($this->vars);	// for memcache
 		
 		// mqtt subscribe
 		$station_setting = $this->sync_data_model->station_setting_query();
@@ -106,6 +106,9 @@ class Cars extends CI_Controller
 		$mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT;
 		$this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid());
 		$this->vars['mqtt']->connect();
+		
+		// init again
+		$this->sync_data_model->init($this->vars);	// for mqtt
         
 		$this->load->model('cars_model'); 
         $this->cars_model->init($this->vars);
diff --git a/controllers/Pks.php b/controllers/Pks.php
index a6c2cf0..72f2981 100644
--- a/controllers/Pks.php
+++ b/controllers/Pks.php
@@ -91,7 +91,7 @@ class Pks extends CI_Controller
 		
 		// 資料介接模組
 		$this->load->model('sync_data_model'); 
-		$this->sync_data_model->init($this->vars);
+		$this->sync_data_model->init($this->vars);	// for memcache
 		
 		// mqtt subscribe
 		$station_setting = $this->sync_data_model->station_setting_query();
@@ -99,6 +99,9 @@ class Pks extends CI_Controller
 		$mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT;
 		$this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid());
 		$this->vars['mqtt']->connect();
+		
+		// init again
+		$this->sync_data_model->init($this->vars);	// for mqtt
 	}