diff --git a/websocket-handler.ts b/websocket-handler.ts index c21ff0e..4c7c1ce 100644 --- a/websocket-handler.ts +++ b/websocket-handler.ts @@ -64,8 +64,11 @@ export function processMessage(ws: WS, messageString: string): void { } ); guardStringNotEmpty(messageObject.messageChannel, (messageChannel) => { - if (!messageObject.messageBody) return; - sendMessage(messageChannel, messageObject.messageBody); + const body = messageObject.messageBody; + if (body == undefined) return; + + const channels = messageChannel.split("/"); + channels.forEach((channel) => sendMessage(channel, body)); }); }