Start connection of a specific gateway.
(self, setting: dict, gateway_name: str)
| 232 | return self.exchanges |
| 233 | |
| 234 | def connect(self, setting: dict, gateway_name: str) -> None: |
| 235 | """ |
| 236 | Start connection of a specific gateway. |
| 237 | """ |
| 238 | gateway: BaseGateway | None = self.get_gateway(gateway_name) |
| 239 | if gateway: |
| 240 | self.write_log(_("连接登录 -> {}").format(gateway_name)) |
| 241 | |
| 242 | gateway.connect(setting) |
| 243 | |
| 244 | def subscribe(self, req: SubscribeRequest, gateway_name: str) -> None: |
| 245 | """ |
no test coverage detected