old mode 100644
new mode 100755
 |  |  | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeFactory; | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeForServerStarted; | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem; | 
 |  |  | import com.genersoft.iot.vmp.service.IMediaServerService; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | 
 |  |  | import java.util.concurrent.ConcurrentHashMap; | 
 |  |  |  | 
 |  |  | @Component | 
 |  |  | @Order(value=1) | 
 |  |  | @Order(value=12) | 
 |  |  | public class ZLMRunner implements CommandLineRunner { | 
 |  |  |  | 
 |  |  |     private final static Logger logger = LoggerFactory.getLogger(ZLMRunner.class); | 
 |  |  | 
 |  |  |         HookSubscribeForServerStarted hookSubscribeForServerStarted = HookSubscribeFactory.on_server_started(); | 
 |  |  |         // 订阅 zlm启动事件, 新的zlm也会从这里进入系统 | 
 |  |  |         hookSubscribe.addSubscribe(hookSubscribeForServerStarted, | 
 |  |  |                 (MediaServerItem mediaServerItem, JSONObject response)->{ | 
 |  |  |             ZLMServerConfig zlmServerConfig = response.to(ZLMServerConfig.class); | 
 |  |  |                 (mediaServerItem, hookParam)->{ | 
 |  |  |             ZLMServerConfig zlmServerConfig = (ZLMServerConfig)hookParam; | 
 |  |  |             if (zlmServerConfig !=null ) { | 
 |  |  |                 if (startGetMedia != null) { | 
 |  |  |                     startGetMedia.remove(zlmServerConfig.getGeneralMediaServerId()); |