File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -405,16 +405,18 @@ async def on_message_for_websocket(
405405 # - timestamp: int (milliseconds since Python time epoch)
406406 # It's essentially time.time() x 1000
407407 r_stream = message_context .consumer .get_stream (message_context .subscriber_name )
408- _LOGGER .debug (
409- "Got msg='%s' stream=%s es_id=%s" ,
408+ _LOGGER .info (
409+ "Got msg='%s' stream=%s es_id=%s /%s/ " ,
410410 msg ,
411411 r_stream ,
412412 es_id ,
413+ es_websocket_uuid ,
413414 )
414- _LOGGER .debug (
415- "With offset=%s timestamp=%s" ,
415+ _LOGGER .info (
416+ "With offset=%s timestamp=%s /%s/ " ,
416417 message_context .offset ,
417418 message_context .timestamp ,
419+ es_websocket_uuid ,
418420 )
419421 # Update message received count
420422 num_messages_received : int = message_stats [_MESSAGE_STATS_KEY_RECEIVED ] + 1
@@ -479,7 +481,6 @@ async def on_message_for_websocket(
479481 != message_stats [_MESSAGE_STATS_KEY_SENT ]
480482 ):
481483 _LOGGER .info ("COUNT MISMATCH %s" , message_stats )
482- _LOGGER .info ("Last message: %s" , message_string )
483484
484485 # Consider regular INFO summary.
485486 # Stats will ultimately be produced if the socket closes,
You can’t perform that action at this time.
0 commit comments