METHOD_0 ( ) { METHOD_1 ( METHOD_2 ( 0 ) , 3 ) ; METHOD_1 ( METHOD_2 ( 1 ) , 3 ) ; METHOD_1 ( METHOD_2 ( 2 ) , 3 ) ; org . apache . activemq . artemis . api . core . IDENT_0 IDENT_1 = org . apache . activemq . artemis . api . core . IDENT_0 . METHOD_3 ( STRING_0 ) ; org . apache . activemq . artemis . core . IDENT_2 . impl . IDENT_3 as = new org . apache . activemq . artemis . core . IDENT_2 . impl . METHOD_4 ( ) ; as . METHOD_5 ( IDENT_1 ) ; as . METHOD_6 ( IDENT_1 ) ; for ( int i = 0 ; i <= 2 ; i ++ ) { METHOD_7 ( i , STRING_1 , STRING_2 , null , true ) ; METHOD_2 ( i ) . METHOD_7 ( IDENT_1 , IDENT_4 . IDENT_5 , IDENT_1 , null , true , false ) ; METHOD_2 ( i ) . METHOD_8 ( ) . METHOD_9 ( STRING_3 , as ) ; } for ( org . apache . activemq . artemis . core . server . cluster . IDENT_6 IDENT_7 : METHOD_2 ( 0 ) . METHOD_10 ( ) . METHOD_11 ( ) ) { for ( org . apache . activemq . artemis . core . server . cluster . IDENT_8 record : ( ( org . apache . activemq . artemis . core . server . cluster . impl . IDENT_9 ) ( IDENT_7 ) ) . METHOD_12 ( ) . values ( ) ) { record . METHOD_13 ( ) . METHOD_14 ( ) ; } } org . apache . activemq . artemis . api . core . client . IDENT_10 sf = IDENT_11 [ 0 ] ; org . apache . activemq . artemis . api . core . client . IDENT_12 session = sf . METHOD_15 ( false , false ) ; org . apache . activemq . artemis . api . core . client . IDENT_13 IDENT_14 = session . METHOD_16 ( STRING_1 ) ; for ( int i = 0 ; i < 1000 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_15 message = session . METHOD_17 ( true ) ; message . METHOD_18 ( INT_0 ) ; IDENT_14 . METHOD_19 ( message ) ; } session . commit ( ) ; session . start ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_16 consumer = session . METHOD_20 ( STRING_0 ) ; for ( int i = 0 ; i < 1000 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_15 message = consumer . METHOD_21 ( INT_1 ) ; "<AssertPlaceHolder>" ; message . METHOD_22 ( ) ; } session . commit ( ) ; session . close ( ) ; } METHOD_21 ( long ) { session . METHOD_23 ( ) ; try { if ( IDENT_17 . LOGGER . METHOD_24 ( ) ) { IDENT_17 . LOGGER . trace ( ( ( ( STRING_4 + ( this ) ) + STRING_5 ) + IDENT_18 ) ) ; } METHOD_25 ( ) ; javax . jms . Message message = consumer . METHOD_21 ( IDENT_18 ) ; if ( IDENT_17 . LOGGER . METHOD_24 ( ) ) { IDENT_17 . LOGGER . trace ( ( ( ( STRING_6 + ( this ) ) + STRING_7 ) + message ) ) ; } if ( message == null ) { return null ; } else { return METHOD_26 ( message ) ; } } finally { session . METHOD_27 ( ) ; } }
org . junit . Assert . assertNotNull ( message )