METHOD_0 ( ) { org . apache . activemq . artemis . core . config . Configuration config = METHOD_1 ( ) . METHOD_2 ( false ) . METHOD_3 ( false ) ; java . util . HashMap < java . lang . String , org . apache . activemq . artemis . core . IDENT_0 . impl . IDENT_1 > IDENT_0 = new java . util . HashMap ( ) ; org . apache . activemq . artemis . core . IDENT_0 . impl . IDENT_1 IDENT_2 = new org . apache . activemq . artemis . core . IDENT_0 . impl . METHOD_4 ( ) . METHOD_5 ( ( ( 20 * INT_0 ) * INT_0 ) ) ; IDENT_0 . put ( STRING_0 , IDENT_2 ) ; server = METHOD_6 ( METHOD_7 ( true , config , ( ( 10 * INT_0 ) * INT_0 ) , ( ( 20 * INT_0 ) * INT_0 ) , IDENT_0 ) ) ; server . start ( ) ; final int IDENT_3 = INT_1 ; org . apache . activemq . artemis . api . core . client . IDENT_4 factory = METHOD_8 ( IDENT_5 ) ; org . apache . activemq . artemis . api . core . client . IDENT_6 session = METHOD_9 ( factory . METHOD_10 ( null , null , false , false , true , false , ( INT_0 * IDENT_3 ) ) ) ; org . apache . activemq . artemis . api . core . IDENT_7 address = new org . apache . activemq . artemis . api . core . METHOD_11 ( STRING_0 ) ; session . METHOD_12 ( address , address , null , true ) ; org . apache . activemq . artemis . api . core . client . IDENT_8 IDENT_9 = session . METHOD_13 ( address ) ; org . apache . activemq . artemis . api . core . client . IDENT_10 message = METHOD_14 ( session , IDENT_11 . IDENT_12 , new byte [ INT_2 ] , true ) ; for ( int i = 0 ; i < IDENT_3 ; i ++ ) { if ( ( i OP_0 INT_3 ) == 0 ) { System . out . println ( ( STRING_1 + i ) ) ; } IDENT_9 . METHOD_15 ( message ) ; } session . commit ( ) ; session . start ( ) ; org . apache . activemq . artemis . api . core . client . IDENT_13 consumer = session . METHOD_16 ( address ) ; int IDENT_14 = 0 ; org . apache . activemq . artemis . api . core . client . IDENT_10 msg ; do { msg = consumer . METHOD_17 ( INT_3 ) ; if ( msg != null ) { msg . METHOD_18 ( ) ; if ( ( ( ++ IDENT_14 ) OP_0 1000 ) == 0 ) { System . out . println ( ( STRING_2 + IDENT_14 ) ) ; } } } while ( msg != null ) ; session . commit ( ) ; session . close ( ) ; server . METHOD_19 ( ) ; System . out . println ( ( STRING_3 + IDENT_14 ) ) ; server = METHOD_6 ( METHOD_7 ( true , config , ( ( 10 * INT_0 ) * INT_0 ) , ( ( 20 * INT_0 ) * INT_0 ) , IDENT_0 ) ) ; server . start ( ) ; factory = METHOD_8 ( IDENT_5 ) ; session = METHOD_9 ( factory . METHOD_10 ( false , false , false ) ) ; consumer = session . METHOD_16 ( address ) ; session . start ( ) ; do { msg = consumer . METHOD_17 ( INT_3 ) ; if ( msg != null ) { msg . METHOD_18 ( ) ; session . commit ( ) ; if ( ( ( ++ IDENT_14 ) OP_0 1000 ) == 0 ) { System . out . println ( ( STRING_2 + IDENT_14 ) ) ; } } } while ( msg != null ) ; System . out . println ( ( STRING_4 + IDENT_14 ) ) ; "<AssertPlaceHolder>" ; } commit ( ) { boolean result = IDENT_15 ; java . util . Set < org . apache . activemq . artemis . spi . core . security . IDENT_16 . IDENT_17 > IDENT_18 = subject . METHOD_20 ( org . apache . activemq . artemis . spi . core . security . IDENT_16 . IDENT_17 . class ) ; java . util . Set < java . security . IDENT_19 > IDENT_20 = subject . METHOD_20 ( ) ; if ( result ) { IDENT_20 . add ( new org . apache . activemq . artemis . spi . core . security . IDENT_16 . METHOD_21 ( IDENT_21 ) ) ; } for ( org . apache . activemq . artemis . spi . core . security . IDENT_16 . METHOD_21 IDENT_22 : IDENT_18 ) { java . util . List < java . lang . String > IDENT_23 = new java . util . ArrayList ( ) ; try { java . lang . String IDENT_24 = METHOD_22 ( IDENT_22 . getName ( ) , IDENT_23 ) ; METHOD_23 ( context , IDENT_24 , IDENT_22 . getName ( ) , IDENT_23 ) ; } catch ( javax . IDENT_25 . IDENT_26 e ) { METHOD_24 ( ) ; javax . security . auth . IDENT_27 . IDENT_28 ex = new javax . security . auth . IDENT_27 . METHOD_25 ( STRING_5 ) ; ex . METHOD_26 ( e ) ; throw ex ; } } for ( org . apache . activemq . artemis . spi . core . security . IDENT_16 . IDENT_29 IDENT_30 : IDENT_31 ) { IDENT_20 . add ( IDENT_30 ) ; } METHOD_27 ( ) ; return result ; }
org . junit . Assert . assertEquals ( IDENT_3 , IDENT_14 )