METHOD_0 ( ) { IDENT_0 . METHOD_1 ( INT_0 ) . METHOD_2 ( true ) . METHOD_3 ( true ) . METHOD_4 ( 0 ) . METHOD_5 ( INT_1 ) . METHOD_6 ( 100 ) ; if ( ( IDENT_1 ) instanceof org . apache . activemq . artemis . core . server . impl . IDENT_2 ) { ( ( org . apache . activemq . artemis . core . server . impl . IDENT_2 ) ( IDENT_1 ) ) . IDENT_3 = INT_2 ; } org . apache . activemq . artemis . core . client . impl . IDENT_4 IDENT_5 = ( ( org . apache . activemq . artemis . core . client . impl . IDENT_4 ) ( METHOD_7 ( IDENT_0 ) ) ) ; final org . apache . activemq . artemis . api . core . client . IDENT_6 session = METHOD_8 ( IDENT_5 , true , false , false ) ; session . METHOD_9 ( IDENT_7 . IDENT_8 , IDENT_9 . IDENT_10 , IDENT_7 . IDENT_8 , null , true ) ; final org . apache . activemq . artemis . api . core . client . IDENT_11 IDENT_12 = session . METHOD_10 ( IDENT_7 . IDENT_8 ) ; javax . transaction . IDENT_13 . IDENT_14 IDENT_15 = new org . apache . activemq . artemis . core . transaction . impl . METHOD_11 ( STRING_0 . getBytes ( ) , INT_3 , STRING_1 . getBytes ( ) ) ; session . start ( IDENT_15 , IDENT_16 . IDENT_17 ) ; for ( int i = 0 ; i < INT_4 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_18 message = session . METHOD_12 ( true ) ; message . METHOD_13 ( STRING_2 , i ) ; IDENT_12 . METHOD_14 ( message ) ; } session . end ( IDENT_15 , IDENT_16 . IDENT_19 ) ; session . METHOD_15 ( IDENT_15 ) ; METHOD_16 ( true , session ) ; try { session . METHOD_17 ( IDENT_15 ) ; } catch ( javax . transaction . IDENT_13 . IDENT_20 e ) { try { session . METHOD_17 ( IDENT_15 ) ; } catch ( java . lang . Exception IDENT_21 ) { org . apache . activemq . artemis . tests . integration . cluster . IDENT_22 . IDENT_23 . log . trace ( IDENT_21 . getMessage ( ) , IDENT_21 ) ; } } org . apache . activemq . artemis . api . core . client . IDENT_24 consumer = session . METHOD_18 ( IDENT_7 . IDENT_8 ) ; session . start ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_18 m = consumer . METHOD_19 ( 1000 ) ; "<AssertPlaceHolder>" ; } METHOD_19 ( long ) { session . METHOD_20 ( ) ; try { if ( IDENT_25 . LOGGER . METHOD_21 ( ) ) { IDENT_25 . LOGGER . trace ( ( ( ( STRING_3 + ( this ) ) + STRING_4 ) + IDENT_26 ) ) ; } METHOD_22 ( ) ; javax . jms . Message message = consumer . METHOD_19 ( IDENT_26 ) ; if ( IDENT_25 . LOGGER . METHOD_21 ( ) ) { IDENT_25 . LOGGER . trace ( ( ( ( STRING_5 + ( this ) ) + STRING_6 ) + message ) ) ; } if ( message == null ) { return null ; } else { return METHOD_23 ( message ) ; } } finally { session . METHOD_24 ( ) ; } }
org . junit . Assert . assertNull ( m )