joylink/rt-sim-training-client
6
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

socket重复订阅问题修复

Browse Source
This commit is contained in:
fan 2023-05-04 17:23:51 +08:00
parent 0395d6d470
commit bbf9e9ba0e
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/utils/sock.js
View File

@ -37,7 +37,10 @@ StompClient.prototype = {
heartbeatOutgoing: 30000,
onConnect: () => {
this.subscribeMap.forEach(subscribe => {
this.clientIns.subscribe(subscribe.dest, subscribe.handler, subscribe.headers);
if (!subscribe.sub) {
const sub = this.clientIns.subscribe(subscribe.dest, subscribe.handler, subscribe.headers);
this.subscribeMap.set(subscribe.dest, {dest: subscribe.dest, handler: onmessage, sub: sub, headers: subscribe.headers, count: 1});
}
});
Notification.closeAll();
this.status = true;
@ -93,7 +96,6 @@ StompClient.prototype = {
// 订阅指定的topic
subscribe(topic, onmessage, headers) {
console.log(topic, onmessage, headers);
this.topic = topic;
this.onmessage = onmessage;
this.headers = headers;