METHOD_0 ( ) { net . IDENT_0 . IDENT_1 . core . time . IDENT_2 IDENT_3 = new net . IDENT_0 . IDENT_1 . core . time . METHOD_1 ( ) ; try ( final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_5 queue = METHOD_2 ( METHOD_3 ( ) ) . METHOD_4 ( IDENT_6 . IDENT_7 ) . METHOD_5 ( METHOD_5 ) . build ( ) ) { final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_8 IDENT_9 = queue . METHOD_6 ( ) ; final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_10 IDENT_11 = queue . METHOD_7 ( ) ; final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . List < java . lang . String > IDENT_12 = net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . Arrays . asList ( STRING_0 , STRING_1 , STRING_2 ) ; { try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_13 IDENT_14 = IDENT_9 . METHOD_8 ( ) ) { IDENT_14 . METHOD_9 ( ) . write ( ) . bytes ( IDENT_12 . get ( 0 ) . getBytes ( ) ) ; } try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_13 IDENT_14 = IDENT_9 . METHOD_8 ( ) ) { IDENT_14 . METHOD_9 ( ) . write ( ) . bytes ( IDENT_12 . get ( 1 ) . getBytes ( ) ) ; } METHOD_5 . METHOD_10 ( INT_0 ) ; try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_13 IDENT_14 = IDENT_9 . METHOD_8 ( ) ) { IDENT_14 . METHOD_9 ( ) . write ( ) . bytes ( IDENT_12 . get ( 2 ) . getBytes ( ) ) ; } } for ( java . lang . String expected : IDENT_12 ) { try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_4 . IDENT_13 IDENT_15 = IDENT_11 . METHOD_11 ( ) ) { if ( ! ( IDENT_15 . METHOD_12 ( ) ) ) org . junit . Assert . fail ( ) ; java . lang . String text = IDENT_15 . METHOD_9 ( ) . read ( ) . text ( ) ; "<AssertPlaceHolder>" ; } } } } read ( ) { return ( IDENT_16 ) -> { final byte [ ] IDENT_17 = IDENT_16 . read ( ) . bytes ( ) ; if ( IDENT_17 != null ) { net . IDENT_0 . IDENT_1 . queue . IDENT_18 . LOGGER . info ( STRING_3 , new java . lang . String ( IDENT_17 , IDENT_19 . UTF_8 ) ) ; } } ; }
org . junit . Assert . assertEquals ( expected , text )