METHOD_0 ( ) { logger . info ( STRING_0 ) ; java . lang . String message = STRING_1 ; org . apache . IDENT_0 . IDENT_1 transaction = channel . METHOD_1 ( ) ; try { transaction . METHOD_2 ( ) ; logger . info ( STRING_2 ) ; channel . put ( org . apache . IDENT_0 . event . IDENT_2 . METHOD_3 ( message , java . nio . IDENT_3 . IDENT_4 . METHOD_4 ( STRING_3 ) ) ) ; transaction . commit ( ) ; } catch ( java . lang . Throwable e ) { logger . info ( STRING_4 ) ; transaction . METHOD_5 ( ) ; } finally { logger . info ( STRING_5 ) ; transaction . close ( ) ; } java . lang . Thread . sleep ( 1000 ) ; IDENT_5 . process ( ) ; java . lang . Thread . sleep ( 1000 ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( ) { java . lang . String message ; do { message = queue . METHOD_7 ( ) ; } while ( message == null ) ; return message ; }
org . junit . Assert . assertEquals ( message , listener . METHOD_6 ( ) )