@@ -99,9 +99,7 @@ async def stopPushStream(): | |||
msg=EasyExceptionType.EASY_TASK_LIMIT.value[1]) | |||
channel = channelList[0] | |||
if channel["enable"] == "false": | |||
logger.error("EasyRtmpLive任务已停止") | |||
return JsonResult.error(code=EasyExceptionType.TASK_NOT_EXISTS.value[0], | |||
msg=EasyExceptionType.TASK_NOT_EXISTS.value[1]) | |||
logger.info("EasyRtmpLive任务已停止") | |||
channel["enable"] = "false" | |||
channel["srcURL"] = '"%s"' % channel["srcURL"] | |||
req_param = 'indexCode=%s&name=%s&srcURL=%s&connectType=%s&timeout=5&mediaType=%s&dstURL=%s&dstFormat=%s&enable=%s' % \ |
@@ -141,9 +141,7 @@ def handle_rtmp(msg, task, fb_queue, service_config): | |||
channel["enable"] = "true" | |||
if 'stop' == command: | |||
if channel["enable"] == "false": | |||
logger.error("任务停止失败, 任务已停止!") | |||
raise ServiceException(EasyExceptionType.TASK_NOT_EXISTS.value[0], | |||
EasyExceptionType.TASK_NOT_EXISTS.value[1]) | |||
logger.info("EasyRtmpLive任务已停止!") | |||
channel["enable"] = "false" | |||
channel["srcURL"] = '"%s"' % channel["srcURL"] | |||
req_param = 'indexCode=%s&name=%s&srcURL=%s&connectType=%s&timeout=5&mediaType=%s&dstURL=%s&dstFormat=%s&enable=%s' % \ |