diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java
index 41b5d38d2..04f936cb3 100644
--- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java
+++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java
@@ -20,8 +20,11 @@ public abstract class AbstractMessageDistributor implements MessageDistributor {
 		this.webSocketSessionStore = webSocketSessionStore;
 	}
 
-	@Override
-	public void doSend(MessageDO messageDO) {
+	/**
+	 * 对当前服务中的 websocket 连接做消息推送
+	 * @param messageDO 消息实体
+	 */
+	protected void doSend(MessageDO messageDO) {
 
 		// 是否广播发送
 		Boolean needBroadcast = messageDO.getNeedBroadcast();
diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java
index 865986211..0c7ccc693 100644
--- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java
+++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java
@@ -14,10 +14,4 @@ public interface MessageDistributor {
 	 */
 	void distribute(MessageDO messageDO);
 
-	/**
-	 * 发送消息
-	 * @param messageDO 发送的消息
-	 */
-	void doSend(MessageDO messageDO);
-
 }
diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java
index 0a3672478..47fa235ed 100644
--- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java
+++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java
@@ -20,4 +20,3 @@ public abstract class JsonWebSocketMessage {
 	}
 
 }
-