METHOD_0 ( ) { org . apache . activemq . artemis . api . core . client . IDENT_0 session = null ; org . apache . activemq . artemis . tests . integration . client . IDENT_1 . IDENT_2 . METHOD_1 ( ) ; org . apache . activemq . artemis . core . server . IDENT_3 server = METHOD_2 ( true , METHOD_3 ( ) ) ; server . start ( ) ; org . apache . activemq . artemis . core . server . IDENT_4 original = server . METHOD_4 ( ) ; IDENT_5 . METHOD_5 ( true ) . METHOD_6 ( true ) ; org . apache . activemq . artemis . api . core . client . IDENT_6 sf = METHOD_7 ( IDENT_5 ) ; session = sf . METHOD_8 ( false , true , true ) ; session . METHOD_9 ( org . apache . activemq . artemis . tests . integration . client . IDENT_7 , org . apache . activemq . artemis . tests . integration . client . IDENT_7 , true ) ; org . apache . activemq . artemis . api . core . client . IDENT_8 IDENT_9 = session . METHOD_10 ( org . apache . activemq . artemis . tests . integration . client . IDENT_7 ) ; for ( int i = 0 ; i < 10 ; i ++ ) { org . apache . activemq . artemis . api . core . Message IDENT_10 = METHOD_11 ( session , IDENT_11 , true ) ; IDENT_9 . METHOD_12 ( IDENT_10 ) ; } session . commit ( ) ; session . close ( ) ; sf . close ( ) ; server . METHOD_13 ( ) ; server . start ( ) ; sf = METHOD_7 ( IDENT_5 ) ; session = sf . METHOD_8 ( false , false ) ; org . apache . activemq . artemis . api . core . client . IDENT_12 IDENT_13 = session . METHOD_14 ( org . apache . activemq . artemis . tests . integration . client . IDENT_7 ) ; session . start ( ) ; for ( int i = 0 ; i < 10 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_14 msg = IDENT_13 . METHOD_15 ( INT_0 ) ; "<AssertPlaceHolder>" ; msg . METHOD_16 ( new java . io . METHOD_17 ( ) { @ org . apache . activemq . artemis . tests . integration . client . Override public void write ( int b ) throws java . io . IOException { } } ) ; msg . METHOD_18 ( ) ; session . commit ( ) ; } ( ( org . apache . activemq . artemis . core . server . impl . IDENT_15 ) ( server ) ) . METHOD_19 ( original ) ; server . fail ( false ) ; server . start ( ) ; server . METHOD_13 ( ) ; METHOD_20 ( ) ; } METHOD_15 ( long ) { session . METHOD_21 ( ) ; try { if ( IDENT_16 . LOGGER . METHOD_22 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_0 + ( this ) ) + STRING_1 ) + IDENT_17 ) ) ; } METHOD_23 ( ) ; javax . jms . Message message = consumer . METHOD_15 ( IDENT_17 ) ; if ( IDENT_16 . LOGGER . METHOD_22 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_2 + ( this ) ) + STRING_3 ) + message ) ) ; } if ( message == null ) { return null ; } else { return METHOD_24 ( message ) ; } } finally { session . METHOD_25 ( ) ; } }
org . junit . Assert . assertNotNull ( msg )