From 1104212a1826df4443d66b1057e7bb2be6e6e047 Mon Sep 17 00:00:00 2001 From: acgist <289547414@qq.com> Date: Mon, 3 Jul 2023 08:31:45 +0800 Subject: [PATCH] =?UTF-8?q?[*]=20=E6=97=A5=E5=B8=B8=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../acgist/taoyao/signal/party/media/RoomClientId.java | 10 ++++++++++ .../signal/protocol/room/RoomClientListProtocol.java | 6 +++--- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/RoomClientId.java b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/RoomClientId.java index 65e7dad..ab1af5d 100644 --- a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/RoomClientId.java +++ b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/RoomClientId.java @@ -1,5 +1,6 @@ package com.acgist.taoyao.signal.party.media; +import java.util.ArrayList; import java.util.List; import io.swagger.v3.oas.annotations.media.Schema; @@ -33,4 +34,13 @@ public class RoomClientId { @Schema(title = "视频消费者ID", description = "视频消费者ID") private List videoConsumers; + public RoomClientId() { + this.dataProducers = new ArrayList<>(); + this.dataConsumers = new ArrayList<>(); + this.audioProducers = new ArrayList<>(); + this.videoProducers = new ArrayList<>(); + this.audioConsumers = new ArrayList<>(); + this.videoConsumers = new ArrayList<>(); + } + } diff --git a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/room/RoomClientListProtocol.java b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/room/RoomClientListProtocol.java index 55c0d97..2169247 100644 --- a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/room/RoomClientListProtocol.java +++ b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/room/RoomClientListProtocol.java @@ -75,11 +75,11 @@ public class RoomClientListProtocol extends ProtocolRoomAdapter implements Appli @Override public void execute(String clientId, ClientType clientType, Room room, Client client, Client mediaClient, Message message, Map body) { - message.setBody(room.clientStatus()); - client.push(this.build(Map.of( + message.setBody(Map.of( Constant.ROOM_ID, room.getRoomId(), Constant.CLIENTS, room.clientStatus() - ))); + )); + client.push(message); } }