METHOD_0 ( ) { IDENT_0 . METHOD_1 ( true ) . METHOD_2 ( true ) . METHOD_3 ( 15 ) ; org . apache . activemq . artemis . core . client . impl . IDENT_1 sf = METHOD_4 ( IDENT_0 , 2 ) ; session = sf . METHOD_5 ( true , true , 0 ) ; session . METHOD_6 ( org . apache . activemq . artemis . tests . integration . cluster . IDENT_2 . IDENT_3 . IDENT_4 , org . apache . activemq . artemis . tests . integration . cluster . IDENT_2 . IDENT_3 . IDENT_4 , true ) ; org . apache . activemq . artemis . api . core . client . IDENT_5 IDENT_6 = session . METHOD_7 ( org . apache . activemq . artemis . tests . integration . cluster . IDENT_2 . IDENT_3 . IDENT_4 ) ; final int IDENT_7 = 1000 ; for ( int i = 0 ; i < IDENT_7 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_8 msg = session . METHOD_8 ( true ) ; msg . METHOD_9 ( new org . apache . activemq . artemis . api . core . METHOD_10 ( STRING_0 ) , i ) ; msg . METHOD_11 ( ( ( java . lang . System . currentTimeMillis ( ) ) + 1000 ) ) ; IDENT_6 . METHOD_12 ( msg ) ; } METHOD_13 ( session ) ; session . close ( ) ; org . apache . activemq . artemis . core . server . IDENT_9 queue = IDENT_10 . METHOD_14 ( ) . METHOD_15 ( org . apache . activemq . artemis . tests . integration . cluster . IDENT_2 . IDENT_3 . IDENT_4 ) ; long IDENT_11 = ( java . lang . System . currentTimeMillis ( ) ) + INT_0 ; while ( ( IDENT_11 > ( java . lang . System . currentTimeMillis ( ) ) ) && ( queue . METHOD_16 ( ) . METHOD_17 ( ) ) ) { java . lang . Thread . sleep ( 100 ) ; queue . METHOD_18 ( ) ; } "<AssertPlaceHolder>" ; } METHOD_16 ( ) { return IDENT_12 ; }
org . junit . Assert . assertFalse ( queue . METHOD_16 ( ) . METHOD_17 ( ) )