diff --git a/src/mqtt_client_wrapper.cpp b/src/mqtt_client_wrapper.cpp
index de51de1..7b4cff4 100644
--- a/src/mqtt_client_wrapper.cpp
+++ b/src/mqtt_client_wrapper.cpp
@@ -79,7 +79,7 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
 
                 if (switch_val == 0)
                 {
-                    if (!RTMPManager::is_streaming(cam.name))
+                    if (!RTMPManager::is_streaming(cam.name, type))
                     {
                         RTMPManager::start_camera(cam, type);
                         op_result = true;
@@ -87,7 +87,7 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
                 }
                 else
                 {
-                    if (RTMPManager::is_streaming(cam.name))
+                    if (RTMPManager::is_streaming(cam.name, type))
                     {
                         RTMPManager::stop_camera(cam.name, type);
                         op_result = true;