public void logUpdateQueriesForCurrentThread ( ) { List < String > queries = getUpdateQueriesForCurrentThread ( ) . stream ( ) . map ( CircularQueueCaptureQueriesListener :: formatQueryAsSql ) . collect ( Collectors . toList ( ) ) ; ourLog . info ( "Select Queries:\n{}" , String . join ( "\n" , queries ) ) ; }
Log all captured UPDATE queries