METHOD_0 ( ) { final int IDENT_0 = 200 ; org . apache . activemq . artemis . core . server . IDENT_1 server = METHOD_1 ( false , METHOD_2 ( ) ) ; server . start ( ) ; IDENT_2 . METHOD_3 ( 0 ) ; final org . apache . activemq . artemis . api . core . client . IDENT_3 sf = METHOD_4 ( IDENT_2 ) ; { org . apache . activemq . artemis . api . core . client . IDENT_4 session = sf . METHOD_5 ( false , false , false ) ; session . METHOD_6 ( STRING_0 , STRING_0 , true ) ; session . close ( ) ; } final java . util . concurrent . atomic . IDENT_5 IDENT_6 = new java . util . concurrent . atomic . METHOD_7 ( 0 ) ; org . apache . activemq . artemis . api . core . client . IDENT_4 IDENT_7 = sf . METHOD_5 ( false , false ) ; org . apache . activemq . artemis . api . core . client . IDENT_8 IDENT_9 = IDENT_7 . METHOD_8 ( STRING_0 ) ; org . apache . activemq . artemis . api . core . client . IDENT_10 IDENT_11 = IDENT_7 . METHOD_9 ( true ) ; IDENT_11 . METHOD_10 ( STRING_1 , STRING_2 ) ; for ( int i = 0 ; i < IDENT_0 ; i ++ ) { IDENT_9 . METHOD_11 ( IDENT_11 ) ; } IDENT_7 . commit ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_4 session = sf . METHOD_5 ( false , false ) ; org . apache . activemq . artemis . api . core . client . IDENT_12 consumer = session . METHOD_12 ( STRING_0 ) ; session . start ( ) ; while ( true ) { org . apache . activemq . artemis . api . core . client . IDENT_10 msg = consumer . METHOD_13 ( ) ; if ( msg == null ) { System . out . println ( STRING_3 ) ; break ; } msg . METHOD_14 ( ) ; session . commit ( ) ; IDENT_6 . METHOD_15 ( ) ; } "<AssertPlaceHolder>" ; } get ( ) { return buffer . METHOD_16 ( ) ; }
org . junit . Assert . assertEquals ( IDENT_0 , IDENT_6 . get ( ) )