METHOD_0 ( ) { long IDENT_0 = METHOD_1 ( ) ; server . METHOD_2 ( org . apache . activemq . artemis . api . core . IDENT_1 . METHOD_3 ( STRING_0 ) , IDENT_2 . IDENT_3 , org . apache . activemq . artemis . api . core . IDENT_1 . METHOD_3 ( STRING_0 ) , null , true , false ) ; javax . jms . IDENT_4 factory = METHOD_4 ( ) ; javax . jms . IDENT_5 connection = factory . METHOD_5 ( ) ; try { javax . jms . IDENT_6 session = connection . METHOD_6 ( false , IDENT_6 . IDENT_7 ) ; javax . jms . IDENT_8 queue ; if ( protocol . equals ( STRING_1 ) ) { queue = session . METHOD_2 ( STRING_2 ) ; } else { queue = session . METHOD_2 ( STRING_0 ) ; } javax . jms . IDENT_9 IDENT_10 = session . METHOD_7 ( queue ) ; long start = java . lang . System . METHOD_8 ( ) ; for ( int i = 0 ; i < ( ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_12 ) + ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_13 ) ) ; i ++ ) { if ( i == ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_13 ) ) { start = java . lang . System . METHOD_8 ( ) ; } IDENT_10 . METHOD_9 ( session . METHOD_10 ( ) ) ; } long end = java . lang . System . METHOD_8 ( ) ; System . out . println ( ( ( ( STRING_3 + ( end - start ) ) + STRING_4 ) + ( TimeUnit . IDENT_14 . METHOD_11 ( ( end - start ) ) ) ) ) ; System . out . println ( ( ( ( STRING_5 + IDENT_0 ) + STRING_4 ) + ( TimeUnit . IDENT_14 . METHOD_11 ( IDENT_0 ) ) ) ) ; if ( ( end - start ) < IDENT_0 ) { org . junit . Assert . fail ( STRING_6 ) ; } connection . start ( ) ; javax . jms . IDENT_15 consumer = session . METHOD_12 ( queue ) ; for ( int i = 0 ; i < ( ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_12 ) + ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_13 ) ) ; i ++ ) { if ( i == ( org . apache . activemq . artemis . tests . integration . persistence . IDENT_11 . IDENT_13 ) ) { start = java . lang . System . METHOD_8 ( ) ; } javax . jms . Message msg = consumer . METHOD_13 ( INT_0 ) ; "<AssertPlaceHolder>" ; } end = java . lang . System . METHOD_8 ( ) ; System . out . println ( ( ( ( STRING_3 + ( end - start ) ) + STRING_4 ) + ( TimeUnit . IDENT_14 . METHOD_11 ( ( end - start ) ) ) ) ) ; System . out . println ( ( ( ( STRING_5 + IDENT_0 ) + STRING_4 ) + ( TimeUnit . IDENT_14 . METHOD_11 ( IDENT_0 ) ) ) ) ; if ( ( ! ( protocol . equals ( STRING_1 ) ) ) && ( ( end - start ) < IDENT_0 ) ) { org . junit . Assert . fail ( STRING_7 ) ; } } finally { connection . close ( ) ; } } METHOD_13 ( long ) { session . METHOD_14 ( ) ; try { if ( IDENT_16 . LOGGER . METHOD_15 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_8 + ( this ) ) + STRING_9 ) + IDENT_17 ) ) ; } METHOD_16 ( ) ; javax . jms . Message message = consumer . METHOD_13 ( IDENT_17 ) ; if ( IDENT_16 . LOGGER . METHOD_15 ( ) ) { IDENT_16 . LOGGER . trace ( ( ( ( STRING_10 + ( this ) ) + STRING_11 ) + message ) ) ; } if ( message == null ) { return null ; } else { return METHOD_17 ( message ) ; } } finally { session . METHOD_18 ( ) ; } }
org . junit . Assert . assertNotNull ( msg )