File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -406,7 +406,7 @@ async def on_message_for_websocket(
406406 # It's essentially time.time() x 1000
407407 r_stream = message_context .consumer .get_stream (message_context .subscriber_name )
408408 _LOGGER .info (
409- "Got msg='%s' stream=%s es_id=%s /%s/" ,
409+ "Got msg=%s stream=%s es_id=%s /%s/" ,
410410 msg ,
411411 r_stream ,
412412 es_id ,
@@ -462,7 +462,9 @@ async def on_message_for_websocket(
462462 message_string = json .dumps (msg_dict )
463463 try :
464464 # Pass on and count
465+ _LOGGER .info ("SENDING %s" , message_context .offset )
465466 await websocket .send_text (message_string )
467+ _LOGGER .info ("SENT %s" , message_context .offset )
466468 message_stats [_MESSAGE_STATS_KEY_SENT ] = (
467469 message_stats [_MESSAGE_STATS_KEY_SENT ] + 1
468470 )
You can’t perform that action at this time.
0 commit comments