From 2561ff94ec25fb46e2653bdc2745065df42ed60d Mon Sep 17 00:00:00 2001
From: zhongwencool <zhongwencool@gmail.com>
Date: Tue, 20 Feb 2024 09:38:33 +0800
Subject: [PATCH] fix: check channel id exist when get_channel_status

---
 .../src/emqx_bridge_rocketmq_connector.erl            | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl
index a5bfa6437..8c2545216 100644
--- a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl
+++ b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl
@@ -179,11 +179,14 @@ on_remove_channel(
     {ok, NewState}.
 
 on_get_channel_status(
-    _ResId,
-    _ChannelId,
-    _State
+    InstanceId,
+    ChannelId,
+    #{installed_channels := Channels} = State
 ) ->
-    ?status_connected.
+    case maps:find(ChannelId, Channels) of
+        {ok, _} -> on_get_status(InstanceId, State);
+        error -> ?status_disconnected
+    end.
 
 on_get_channels(ResId) ->
     emqx_bridge_v2:get_channels_for_connector(ResId).