| | |
|---|
| | | |
|---|
| | | def run_rabbitmq(self, host: str, user: str, password: str, queue: str) -> None: |
|---|
| | | self._message_queue_thread = MessageQueueThread( |
|---|
| | | host, user, password, queue, self._device_manager) |
|---|
| | | host, user, password, queue, self._device_manager, save_folder) |
|---|
| | | self._message_queue_thread.start() |
|---|
| | | |
|---|
| | | def run_all(self): |
|---|
| | |
|---|
| | | self.run(debug=False, host="0.0.0.0", port=self.port) |
|---|
| | | |
|---|
| | | def send_controll_message(self, device_id, msg): |
|---|
| | | device = self._device_manager.get_device(device_id) |
|---|
| | | device = self._device_manager.get_device(device_id,save_folder) |
|---|
| | | if device is None: |
|---|
| | | channel = device.controll_channel |
|---|
| | | channel.basic_publish( |
|---|
