订阅调整
This commit is contained in:
parent
2f815a0707
commit
a2ae99209f
@ -395,7 +395,10 @@ onMounted(() => {
|
||||
tableRef.value.requestServerInteraction();
|
||||
lineNetStore.alarmInfoListTable = tableRef.value;
|
||||
destinations.forEach((destination) => {
|
||||
socket = webSocketConnect(destination, handler);
|
||||
allSocketsAndDestinations.push({
|
||||
socket: webSocketConnect(destination, handler),
|
||||
destination,
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
@ -584,7 +587,10 @@ function openAlarmDialog(row: any) {
|
||||
});
|
||||
}
|
||||
|
||||
let socket: StompMessagingClient | null = null;
|
||||
let allSocketsAndDestinations: {
|
||||
socket: StompMessagingClient;
|
||||
destination: string;
|
||||
}[] = [];
|
||||
let destinations: string[] = [];
|
||||
function handler(message: Uint8Array) {
|
||||
const storage = alert.NccAlertInfoMessage.deserialize(message);
|
||||
@ -592,8 +598,8 @@ function handler(message: Uint8Array) {
|
||||
}
|
||||
|
||||
onUnmounted(() => {
|
||||
destinations.forEach((destination) => {
|
||||
closeWebSocketConnect(socket, destination);
|
||||
allSocketsAndDestinations.forEach((info) => {
|
||||
closeWebSocketConnect(info.socket, info.destination);
|
||||
});
|
||||
});
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user