METHOD_0 ( ) { METHOD_1 ( ) ; org . apache . activemq . artemis . core . config . Configuration config = METHOD_2 ( ) ; server = METHOD_3 ( true , config , org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_2 , org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_3 ) ; server . start ( ) ; IDENT_4 . METHOD_4 ( true ) . METHOD_5 ( true ) . METHOD_6 ( true ) ; sf = METHOD_7 ( IDENT_4 ) ; org . apache . activemq . artemis . api . core . client . IDENT_5 session = sf . METHOD_8 ( null , null , false , false , true , false , 0 ) ; session . METHOD_9 ( org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_6 , org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_6 , null , true ) ; org . apache . activemq . artemis . core . server . IDENT_7 queue = server . METHOD_10 ( org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_6 ) ; queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_13 ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_8 IDENT_9 = session . METHOD_14 ( org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_6 ) ; org . apache . activemq . artemis . api . core . client . IDENT_10 message ; for ( int i = 0 ; i < 20 ; i ++ ) { message = session . METHOD_15 ( true ) ; org . apache . activemq . artemis . api . core . IDENT_11 IDENT_12 = message . METHOD_16 ( ) ; IDENT_12 . METHOD_17 ( new byte [ 100 * 4 ] ) ; message . METHOD_18 ( new org . apache . activemq . artemis . api . core . METHOD_19 ( STRING_0 ) , i ) ; IDENT_9 . METHOD_20 ( message ) ; session . commit ( ) ; queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_21 ( ) ; } for ( int i = 20 ; i < INT_0 ; i ++ ) { message = session . METHOD_15 ( true ) ; org . apache . activemq . artemis . api . core . IDENT_11 IDENT_12 = message . METHOD_16 ( ) ; IDENT_12 . METHOD_17 ( new byte [ 100 * 4 ] ) ; message . METHOD_18 ( new org . apache . activemq . artemis . api . core . METHOD_19 ( STRING_0 ) , i ) ; IDENT_9 . METHOD_20 ( message ) ; } session . METHOD_22 ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_5 IDENT_13 = sf . METHOD_8 ( false , false ) ; queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_23 ( ) ; queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_24 ( ) . METHOD_25 ( ) ; IDENT_13 . start ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_14 consumer = IDENT_13 . METHOD_26 ( org . apache . activemq . artemis . tests . integration . IDENT_0 . IDENT_1 . IDENT_6 , org . apache . activemq . artemis . api . core . METHOD_19 . METHOD_27 ( STRING_1 ) ) ; for ( int i = 0 ; i < INT_1 ; i ++ ) { org . apache . activemq . artemis . api . core . client . IDENT_10 IDENT_15 = consumer . METHOD_28 ( INT_2 ) ; System . err . println ( ( STRING_2 + IDENT_15 ) ) ; "<AssertPlaceHolder>" ; IDENT_15 . METHOD_29 ( ) ; IDENT_13 . commit ( ) ; queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_24 ( ) . METHOD_25 ( ) ; } queue . METHOD_11 ( ) . METHOD_12 ( ) . METHOD_30 ( ) ; IDENT_13 . close ( ) ; session . close ( ) ; sf . close ( ) ; server . METHOD_31 ( ) ; } METHOD_28 ( long ) { session . METHOD_32 ( ) ; try { if ( IDENT_16 . LOGGER . METHOD_33 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_3 + ( this ) ) + STRING_4 ) + IDENT_17 ) ) ; } METHOD_34 ( ) ; javax . jms . Message message = consumer . METHOD_28 ( IDENT_17 ) ; if ( IDENT_16 . LOGGER . METHOD_33 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_5 + ( this ) ) + STRING_6 ) + message ) ) ; } if ( message == null ) { return null ; } else { return METHOD_35 ( message ) ; } } finally { session . METHOD_36 ( ) ; } }
org . junit . Assert . assertNotNull ( IDENT_15 )