We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2baade3 commit 32ac80eCopy full SHA for 32ac80e
app/app.py
@@ -360,15 +360,8 @@ async def on_message_for_websocket(
360
message_string += (
361
f"|{message_context.offset}|{message_context.timestamp}"
362
)
363
- patched_msg: AMQPMessage = AMQPMessage(
364
- body=bytes(message_string, "utf-8")
365
- )
366
- else:
367
368
369
370
try:
371
- await websocket.send_text(str(patched_msg)[2:-1])
+ await websocket.send_text(message_string)
372
except WebSocketDisconnect:
373
_LOGGER.info("Got WebSocketDisconnect for %s (stopping)...", es_id)
374
shutdown = True
0 commit comments