METHOD_0 ( ) { server . METHOD_1 ( IDENT_0 , IDENT_1 . IDENT_2 , IDENT_0 , null , true , false ) ; java . util . concurrent . atomic . IDENT_3 errors = new java . util . concurrent . atomic . METHOD_2 ( 0 ) ; java . util . concurrent . atomic . IDENT_4 IDENT_5 = new java . util . concurrent . atomic . METHOD_3 ( true ) ; java . lang . IDENT_6 IDENT_7 = new java . lang . METHOD_4 ( ) { @ org . apache . activemq . artemis . tests . integration . IDENT_8 . Override public void run ( ) { try { javax . jms . IDENT_9 factory = METHOD_5 ( ) ; javax . jms . IDENT_10 connection = factory . METHOD_6 ( ) ; javax . jms . IDENT_11 session = connection . METHOD_7 ( ) ; connection . start ( ) ; javax . jms . IDENT_12 queue = session . METHOD_1 ( IDENT_0 . toString ( ) ) ; while ( IDENT_5 . get ( ) ) { javax . jms . IDENT_13 consumer = session . METHOD_8 ( queue ) ; javax . jms . IDENT_14 message = ( ( javax . jms . IDENT_14 ) ( consumer . METHOD_9 ( 100 ) ) ) ; if ( message != null ) { consumer . close ( ) ; } } connection . close ( ) ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; errors . METHOD_10 ( ) ; } } } ; java . lang . Thread [ ] IDENT_15 = new java . lang . Thread [ 10 ] ; for ( int i = 0 ; i < ( IDENT_15 . length ) ; i ++ ) { IDENT_15 [ i ] = new java . lang . Thread ( IDENT_7 ) ; IDENT_15 [ i ] . start ( ) ; } javax . jms . IDENT_9 factory = METHOD_5 ( ) ; javax . jms . IDENT_10 connection = factory . METHOD_6 ( ) ; javax . jms . IDENT_11 session = connection . METHOD_7 ( ) ; javax . jms . IDENT_12 queue = session . METHOD_1 ( IDENT_0 . toString ( ) ) ; javax . jms . IDENT_16 IDENT_17 = session . METHOD_11 ( queue ) ; final int IDENT_18 = INT_0 ; for ( int i = 0 ; i < IDENT_18 ; i ++ ) { IDENT_17 . METHOD_12 ( session . METHOD_13 ( ( STRING_0 + i ) ) ) ; } IDENT_5 . set ( false ) ; for ( java . lang . Thread c : IDENT_15 ) { c . join ( ) ; } "<AssertPlaceHolder>" ; } get ( ) { return buffer . METHOD_14 ( ) ; }
org . junit . Assert . assertEquals ( 0 , errors . get ( ) )