METHOD_0 ( ) { final java . io . File path = net . IDENT_0 . IDENT_1 . queue . IDENT_2 . METHOD_1 ( STRING_0 ) ; final java . util . concurrent . atomic . IDENT_3 IDENT_4 = new java . util . concurrent . atomic . METHOD_2 ( ) ; net . IDENT_0 . IDENT_1 . queue . IDENT_5 IDENT_6 = net . IDENT_0 . IDENT_1 . queue . IDENT_7 . METHOD_3 ( ) ; net . IDENT_0 . IDENT_1 . queue . IDENT_8 IDENT_9 = IDENT_10 . METHOD_4 ( ( ) -> { try { final net . IDENT_0 . IDENT_1 . queue . IDENT_11 IDENT_12 = net . IDENT_0 . IDENT_1 . queue . IDENT_11 . METHOD_5 ( path ) . METHOD_6 ( ) . build ( ) ; final net . IDENT_0 . IDENT_1 . queue . IDENT_13 IDENT_14 = IDENT_12 . METHOD_7 ( ) ; final net . IDENT_0 . IDENT_1 . bytes . IDENT_15 message = net . IDENT_0 . IDENT_1 . bytes . IDENT_15 . METHOD_8 ( ) ; for ( int i = 0 ; i < ( net . IDENT_0 . IDENT_1 . queue . IDENT_16 . IDENT_17 ) ; i ++ ) { message . METHOD_9 ( ) ; message . append ( i ) ; IDENT_14 . METHOD_10 ( message ) ; } message . METHOD_11 ( ) ; } catch ( t ) { net . IDENT_0 . IDENT_1 . queue . t . printStackTrace ( ) ; } } ) ; IDENT_10 . METHOD_12 ( ) ; IDENT_6 . METHOD_12 ( ) ; long end = ( java . lang . System . currentTimeMillis ( ) ) + INT_0 ; IDENT_9 . get ( INT_0 , TimeUnit . IDENT_18 ) ; IDENT_19 . get ( ( end - ( java . lang . System . currentTimeMillis ( ) ) ) , TimeUnit . IDENT_18 ) ; "<AssertPlaceHolder>" ; } get ( ) { if ( ( IDENT_20 ) == null ) { IDENT_20 = new net . IDENT_0 . IDENT_1 . IDENT_21 . METHOD_13 ( false ) ; IDENT_22 = true ; } return new net . IDENT_0 . IDENT_1 . queue . service . METHOD_14 ( this ) ; }
org . junit . Assert . assertEquals ( net . IDENT_0 . IDENT_1 . queue . IDENT_16 . IDENT_17 , IDENT_4 . get ( ) )