METHOD_0 ( ) { com . IDENT_0 . IDENT_1 . test . IDENT_2 IDENT_3 = new com . IDENT_0 . IDENT_1 . test . METHOD_1 ( messages , true , false ) ; java . util . concurrent . IDENT_4 < java . lang . String > queue = new java . util . concurrent . IDENT_5 < java . lang . String > ( 10 ) ; com . IDENT_0 . IDENT_1 . core . processor . IDENT_6 processor = new com . IDENT_0 . IDENT_1 . core . processor . METHOD_2 ( queue ) ; int count = METHOD_3 ( IDENT_3 , processor , queue ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( com . IDENT_0 . IDENT_1 . test . METHOD_1 , com . IDENT_0 . IDENT_1 . core . processor . IDENT_6 , java . util . concurrent . IDENT_4 ) { int count = 0 ; try { java . io . InputStream stream = IDENT_3 . METHOD_4 ( ) ; processor . METHOD_5 ( stream ) ; while ( count < ( ( messages . length ) * 2 ) ) { processor . process ( ) ; org . junit . Assert . assertTrue ( messages [ count ] . equals ( queue . METHOD_6 ( ) . trim ( ) ) ) ; count ++ ; } org . junit . Assert . fail ( ) ; } catch ( java . io . IOException e ) { } return count ; }
org . junit . Assert . assertEquals ( messages . length , count )