| | |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.*;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.event.EventPublisher;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.session.SSRCFactory;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.callback.DeferredResultHolder;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.callback.RequestMessage;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private AssistRESTfulUtils assistRESTfulUtils;
|
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private SSRCFactory ssrcFactory;
|
|---|
| | |
|
|---|
| | | @Qualifier("taskExecutor")
|
|---|
| | | @Autowired
|
|---|
| | |
|---|
| | | if (sendRtpItems.size() > 0) {
|
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) {
|
|---|
| | | ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(sendRtpItem.getPlatformId());
|
|---|
| | | ssrcFactory.releaseSsrc(sendRtpItem.getMediaServerId(), sendRtpItem.getSsrc());
|
|---|
| | | try {
|
|---|
| | | commanderFroPlatform.streamByeCmd(parentPlatform, sendRtpItem.getCallId());
|
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) {
|
|---|
