diff --git a/streaming/index.js b/streaming/index.js index 9b43112d2..aabd2f855 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -828,7 +828,11 @@ const startServer = async () => { return; } - ws.send(JSON.stringify({ stream: streamName, event, payload })); + ws.send(JSON.stringify({ stream: streamName, event, payload }), (err) => { + if (err) { + log.error(req.requestId, `Failed to send to websocket: ${err}`); + } + }); }; /**