Shikong/gb28181-docking-platform
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更正 GenericSubscribe compile -> complete

Browse Source
This commit is contained in:
shikong 2023-10-03 13:50:41 +08:00
parent 369919ca29
commit d9ab07f1ef
6 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/GenericSubscribe.java
View File

@ -19,7 +19,7 @@ public interface GenericSubscribe<T> {
void addSubscribe(String key,Flow.Subscriber<T> subscribe); void addSubscribe(String key,Flow.Subscriber<T> subscribe);
void delPublisher(String key); void delPublisher(String key);
void compile(String key); void complete(String key);
class Helper { class Helper {
public final static String SEPARATOR = ":"; public final static String SEPARATOR = ":";

2
gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/InviteSubscribe.java
View File

@ -30,7 +30,7 @@ public class InviteSubscribe implements GenericSubscribe<SIPResponse> {
Helper.addSubscribe(publishers, key, subscribe); Helper.addSubscribe(publishers, key, subscribe);
} }
public void compile(String key){ public void complete(String key){
delPublisher(key); delPublisher(key);
} }

2
gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/RecordInfoSubscribe.java
View File

@ -30,7 +30,7 @@ public class RecordInfoSubscribe implements GenericSubscribe<RecordInfoResponseD
Helper.addSubscribe(publishers, key, subscribe); Helper.addSubscribe(publishers, key, subscribe);
} }
public void compile(String key){ public void complete(String key){
delPublisher(key); delPublisher(key);
} }

2
gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipRequestSubscribe.java
View File

@ -33,7 +33,7 @@ public class SipRequestSubscribe implements GenericTimeoutSubscribe<SIPRequest>,
Helper.addSubscribe(publishers, key, subscribe); Helper.addSubscribe(publishers, key, subscribe);
} }
public void compile(String key){ public void complete(String key){
delPublisher(key); delPublisher(key);
} }

2
gb28181-service/src/main/java/cn/skcks/docking/gb28181/core/sip/message/subscribe/SipResponseSubscribe.java
View File

@ -33,7 +33,7 @@ public class SipResponseSubscribe implements GenericTimeoutSubscribe<SIPResponse
Helper.addSubscribe(publishers, key, subscribe); Helper.addSubscribe(publishers, key, subscribe);
} }
public void compile(String key){ public void complete(String key){
delPublisher(key); delPublisher(key);
} }

3
gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/catalog/CatalogService.java
View File

@ -5,7 +5,6 @@ import cn.skcks.docking.gb28181.core.sip.message.request.SipRequestBuilder;
import cn.skcks.docking.gb28181.core.sip.message.subscribe.GenericSubscribe; import cn.skcks.docking.gb28181.core.sip.message.subscribe.GenericSubscribe;
import cn.skcks.docking.gb28181.core.sip.message.subscribe.SipSubscribe; import cn.skcks.docking.gb28181.core.sip.message.subscribe.SipSubscribe;
import cn.skcks.docking.gb28181.core.sip.service.SipService; import cn.skcks.docking.gb28181.core.sip.service.SipService;
import cn.skcks.docking.gb28181.orm.mybatis.dynamic.mapper.DockingDeviceChannelMapper;
import cn.skcks.docking.gb28181.orm.mybatis.dynamic.model.DockingDevice; import cn.skcks.docking.gb28181.orm.mybatis.dynamic.model.DockingDevice;
import cn.skcks.docking.gb28181.orm.mybatis.dynamic.model.DockingDeviceChannel; import cn.skcks.docking.gb28181.orm.mybatis.dynamic.model.DockingDeviceChannel;
import cn.skcks.docking.gb28181.service.device.DeviceChannelService; import cn.skcks.docking.gb28181.service.device.DeviceChannelService;
@ -89,7 +88,7 @@ public class CatalogService {
data.addAll(catalogResponseDTO.getDeviceList().getDeviceList()); data.addAll(catalogResponseDTO.getDeviceList().getDeviceList());
if(curNum >= sumNum){ if(curNum >= sumNum){
log.info("获取完成 {}", key); log.info("获取完成 {}", key);
subscribe.getSipRequestSubscribe().compile(key); subscribe.getSipRequestSubscribe().complete(key);
} else { } else {
subscription.request(1); subscription.request(1);
} }