diff --git a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/GenericSubscribe.java b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/GenericSubscribe.java index 3c7a8af..ae1710a 100644 --- a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/GenericSubscribe.java +++ b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/GenericSubscribe.java @@ -19,7 +19,7 @@ public interface GenericSubscribe { void addSubscribe(String key,Flow.Subscriber subscribe); void delPublisher(String key); - void compile(String key); + void complete(String key); class Helper { public final static String SEPARATOR = ":"; diff --git a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/InviteSubscribe.java b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/InviteSubscribe.java index 9fc7ed1..ae2386e 100644 --- a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/InviteSubscribe.java +++ b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/InviteSubscribe.java @@ -30,7 +30,7 @@ public class InviteSubscribe implements GenericSubscribe { Helper.addSubscribe(publishers, key, subscribe); } - public void compile(String key){ + public void complete(String key){ delPublisher(key); } diff --git a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/RecordInfoSubscribe.java b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/RecordInfoSubscribe.java index 92ffc50..fb6164f 100644 --- a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/RecordInfoSubscribe.java +++ b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/RecordInfoSubscribe.java @@ -30,7 +30,7 @@ public class RecordInfoSubscribe implements GenericSubscribe, Helper.addSubscribe(publishers, key, subscribe); } - public void compile(String key){ + public void complete(String key){ delPublisher(key); } diff --git a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipResponseSubscribe.java b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipResponseSubscribe.java index 1caa348..178c59b 100644 --- a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipResponseSubscribe.java +++ b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipResponseSubscribe.java @@ -33,7 +33,7 @@ public class SipResponseSubscribe implements GenericTimeoutSubscribe= sumNum){ log.info("获取完成 {}", key); - subscribe.getSipRequestSubscribe().compile(key); + subscribe.getSipRequestSubscribe().complete(key); } else { subscription.request(1); }