diff --git a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java index 6bff4e7..af217fa 100644 --- a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java +++ b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java @@ -149,7 +149,7 @@ public class Gb28181DownloadService { public SipSender.SendRequest inviteRequest(WvpProxyDocking docking, WvpProxyDevice device, GB28181Description description, MediaSdpHelper.Action action, String ssrc, String streamId, CompletableFuture result, long time) { return (provider, ip, port) -> { CallIdHeader callId = provider.getNewCallId(); - String subscribeKey = GenericSubscribe.Helper.getKey(Request.INVITE, callId.getCallId()); + String subscribeKey = GenericSubscribe.Helper.getKey(Request.INVITE, action.getAction(), callId.getCallId()); subscribe.getInviteSubscribe().addPublisher(subscribeKey); Flow.Subscriber subscriber = inviteSubscriber(subscribeKey, ssrc, streamId, result, time); subscribe.getInviteSubscribe().addSubscribe(subscribeKey, subscriber);