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); } }