test ( ) { final org . apache . IDENT_0 . common . IDENT_1 config = METHOD_0 ( ) ; org . apache . IDENT_0 . IDENT_2 . IDENT_3 IDENT_4 = org . apache . IDENT_0 . IDENT_2 . IDENT_3 . getInstance ( config ) ; org . apache . IDENT_0 . IDENT_2 . IDENT_5 IDENT_6 = org . apache . IDENT_0 . IDENT_2 . IDENT_5 . getInstance ( config ) ; final java . lang . String [ ] IDENT_7 = new java . lang . String [ ] { STRING_0 , STRING_1 , STRING_2 , STRING_3 } ; final int n = IDENT_7 . length ; final int IDENT_8 = 100 ; final org . apache . IDENT_0 . IDENT_2 . model . IDENT_9 IDENT_10 = IDENT_6 . METHOD_1 ( STRING_4 ) ; final java . util . List < org . apache . IDENT_0 . IDENT_2 . IDENT_11 > IDENT_12 = new java . util . ArrayList ( ) ; for ( java . lang . String name : IDENT_7 ) { IDENT_12 . add ( IDENT_4 . METHOD_2 ( name , IDENT_13 . IDENT_14 , IDENT_10 , null ) ) ; } final java . util . concurrent . atomic . IDENT_15 IDENT_16 = new java . util . concurrent . atomic . METHOD_3 ( ) ; final java . util . IDENT_17 < java . lang . Exception > exceptions = new java . util . METHOD_4 ( ) ; java . lang . Thread IDENT_18 = new java . lang . Thread ( ) { @ org . apache . IDENT_0 . IDENT_2 . Override public void run ( ) { try { java . util . IDENT_19 IDENT_20 = new java . util . METHOD_5 ( ) ; while ( ( IDENT_16 . get ( ) ) == 0 ) { java . lang . String name = IDENT_7 [ IDENT_20 . METHOD_6 ( n ) ] ; org . apache . IDENT_0 . IDENT_2 . IDENT_3 . getInstance ( config ) . METHOD_7 ( name ) ; java . lang . Thread . sleep ( 1 ) ; } } catch ( java . lang . Exception ex ) { org . apache . IDENT_0 . IDENT_2 . IDENT_21 . logger . error ( STRING_5 , ex ) ; exceptions . add ( ex ) ; } } } ; IDENT_18 . start ( ) ; java . lang . Thread [ ] IDENT_22 = new java . lang . Thread [ n ] ; for ( int i = 0 ; i < n ; i ++ ) { final java . lang . String IDENT_23 = IDENT_7 [ i ] ; IDENT_22 [ i ] = new java . lang . Thread ( ) { @ org . apache . IDENT_0 . IDENT_2 . Override public void run ( ) { try { java . util . METHOD_5 IDENT_20 = new java . util . METHOD_5 ( ) ; for ( int i = 0 ; i < IDENT_8 ; i ++ ) { org . apache . IDENT_0 . IDENT_2 . IDENT_3 IDENT_24 = org . apache . IDENT_0 . IDENT_2 . IDENT_3 . getInstance ( config ) ; org . apache . IDENT_0 . IDENT_2 . IDENT_11 IDENT_2 = IDENT_24 . METHOD_8 ( IDENT_23 ) ; IDENT_24 . METHOD_9 ( IDENT_2 , new org . apache . IDENT_0 . metadata . model . IDENT_25 . METHOD_10 ( ( ( long ) ( i ) ) , ( ( ( long ) ( i ) ) + 1 ) ) ) ; java . lang . Thread . sleep ( IDENT_20 . METHOD_6 ( 1 ) ) ; } } catch ( java . lang . Exception ex ) { org . apache . IDENT_0 . IDENT_2 . IDENT_21 . logger . error ( STRING_6 , ex ) ; exceptions . add ( ex ) ; } } } ; IDENT_22 [ i ] . start ( ) ; } for ( int i = 0 ; i < n ; i ++ ) { IDENT_22 [ i ] . join ( ) ; } IDENT_16 . METHOD_11 ( ) ; IDENT_18 . join ( ) ; if ( ( exceptions . isEmpty ( ) ) == false ) { org . apache . IDENT_0 . IDENT_2 . IDENT_21 . logger . error ( ( ( exceptions . size ( ) ) + STRING_7 ) ) ; org . junit . Assert . fail ( ) ; } for ( int i = 0 ; i < n ; i ++ ) { org . apache . IDENT_0 . IDENT_2 . IDENT_11 IDENT_2 = IDENT_4 . METHOD_8 ( IDENT_7 [ i ] ) ; "<AssertPlaceHolder>" ; } } METHOD_12 ( ) { return IDENT_26 ; }
org . junit . Assert . assertEquals ( IDENT_8 , IDENT_2 . METHOD_12 ( ) . size ( ) )