diff --git a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/ClientWrapper.java b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/ClientWrapper.java
index 4aef186..19d88dd 100644
--- a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/ClientWrapper.java
+++ b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/ClientWrapper.java
@@ -94,10 +94,12 @@ public class ClientWrapper implements AutoCloseable {
 	private Transport recvTransport;
 	/**
 	 * 生产者
+	 * 生产者里面的消费者是其他终端消费当前终端的消费者
 	 */
 	private final Map<String, Producer> producers;
     /**
      * 消费者
+     * 当前终端消费其他终端的消费者
      */
     private final Map<String, Consumer> consumers;
 	/**
@@ -154,7 +156,7 @@ public class ClientWrapper implements AutoCloseable {
      */
     public void remove(ClientWrapper wrapper) {
         this.consumers.entrySet().stream()
-        .filter(v -> v.getValue().getConsumeClient() == wrapper)
+        .filter(v -> v.getValue().getProducer().getProduceClient() == wrapper)
         .map(Map.Entry::getKey)
         .forEach(this.consumers::remove);
         // TODO：资源释放
diff --git a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaConsumeProtocol.java b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaConsumeProtocol.java
index f05f799..2adbb25 100644
--- a/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaConsumeProtocol.java
+++ b/taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaConsumeProtocol.java
@@ -117,9 +117,13 @@ public class MediaConsumeProtocol extends ProtocolRoomAdapter implements Applica
         if(consumeClientWrapper.consume(producer)) {
             // TODO：回调媒体服务准备完成
             if(log.isDebugEnabled()) {
-                log.debug("已经消费：{}", consumeClientWrapper.getClientId(), producer.getStreamId());
+                log.debug("已经消费媒体：{} - {}", consumeClientWrapper.getClientId(), producer.getStreamId());
             }
             return;
+        } else {
+            if(log.isDebugEnabled()) {
+                log.debug("消费媒体：{} - {}", consumeClientWrapper.getClientId(), producer.getStreamId());
+            }
         }
         final String clientId = consumeClientWrapper.getClientId();
         final String streamId = producer.getStreamId() + "->" + clientId;