优化多wvp国标级联推流

648540858

2024-04-16 b4168c02cba462571dd3f5bdc1d0b1ffddbc938a

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/ByeRequestProcessor.java

@@ -19,7 +19,6 @@
import com.genersoft.iot.vmp.service.*;
import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
import com.genersoft.iot.vmp.service.bean.RequestStopPushStreamMsg;
import com.genersoft.iot.vmp.service.redisMsg.RedisGbPlayMsgListener;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
import gov.nist.javax.sip.message.SIPRequest;
@@ -98,8 +97,6 @@
   @Autowired
   private IStreamPushService pushService;

   @Autowired
   private RedisGbPlayMsgListener redisGbPlayMsgListener;

   @Override
   public void afterPropertiesSet() throws Exception {
@@ -142,7 +139,7 @@
               ParentPlatform platform = platformService.queryPlatformByServerGBId(sendRtpItem.getPlatformId());
               if (platform != null) {
                  RequestStopPushStreamMsg streamMsg = RequestStopPushStreamMsg.getInstance(sendRtpItem, platform.getName(), platform.getId());
                  redisGbPlayMsgListener.sendMsgForStopSendRtpStream(sendRtpItem.getServerId(), streamMsg);
//                  redisGbPlayMsgListener.sendMsgForStopSendRtpStream(sendRtpItem.getServerId(), streamMsg);
               }
            }else {
               MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());