METHOD_0 ( ) { init ( ) ; IDENT_0 . start ( ) ; final org . apache . IDENT_1 . IDENT_2 . protocol . IDENT_3 response = org . apache . IDENT_1 . IDENT_2 . protocol . IDENT_3 . METHOD_1 ( org . apache . IDENT_1 . common . protocol . header . IDENT_4 . IDENT_5 . class ) ; response . METHOD_2 ( IDENT_6 . IDENT_7 ) ; response . METHOD_3 ( null ) ; org . apache . IDENT_1 . common . protocol . body . IDENT_8 IDENT_9 = new org . apache . IDENT_1 . common . protocol . body . METHOD_4 ( ) ; when ( IDENT_10 . METHOD_5 ( ) ) . thenReturn ( com . google . common . collect . Lists . asList ( IDENT_11 , IDENT_12 , new java . lang . String [ ] { IDENT_13 } ) ) ; when ( IDENT_10 . METHOD_6 ( anyString ( ) , any ( org . apache . IDENT_1 . IDENT_2 . protocol . IDENT_3 . class ) , METHOD_7 ( ) ) ) . METHOD_8 ( new org . mockito . IDENT_14 . IDENT_15 < org . apache . IDENT_1 . IDENT_2 . protocol . IDENT_3 > ( ) { @ org . apache . IDENT_1 . IDENT_16 . Override public org . apache . IDENT_1 . IDENT_2 . protocol . IDENT_3 METHOD_9 ( org . mockito . IDENT_17 . IDENT_18 IDENT_17 ) throws java . lang . Throwable { if ( ( IDENT_17 . METHOD_10 ( 0 ) ) == ( IDENT_11 ) ) { return response ; } else if ( ( IDENT_17 . METHOD_10 ( 0 ) ) == ( IDENT_12 ) ) { return response ; } else if ( ( IDENT_17 . METHOD_10 ( 0 ) ) == ( IDENT_13 ) ) { TimeUnit . IDENT_19 . sleep ( ( ( IDENT_20 ) + 20 ) ) ; return response ; } return response ; } } ) ; java . util . List < org . apache . IDENT_1 . common . IDENT_4 . IDENT_21 > IDENT_22 = IDENT_0 . METHOD_11 ( IDENT_23 , IDENT_24 , IDENT_25 , IDENT_26 , STRING_0 , IDENT_9 , com . google . common . collect . Lists . < java . lang . String > newArrayList ( ) , false , IDENT_20 , true ) ; "<AssertPlaceHolder>" ; } METHOD_11 ( java . lang . String , java . lang . String , java . lang . String , long , java . lang . String , org . apache . IDENT_1 . common . protocol . body . METHOD_4 , java . util . List , boolean , int , boolean ) { final java . util . List < org . apache . IDENT_1 . common . IDENT_4 . IDENT_21 > IDENT_22 = com . google . common . collect . Lists . newArrayList ( ) ; java . util . List < java . lang . String > IDENT_27 = this . IDENT_28 . METHOD_5 ( ) ; if ( ( IDENT_27 != null ) && ( ( IDENT_27 . size ( ) ) > 0 ) ) { final org . apache . IDENT_1 . common . protocol . header . IDENT_4 . IDENT_29 IDENT_30 = new org . apache . IDENT_1 . common . protocol . header . IDENT_4 . METHOD_12 ( ) ; IDENT_30 . METHOD_13 ( IDENT_24 ) ; IDENT_30 . METHOD_14 ( IDENT_26 ) ; IDENT_30 . METHOD_15 ( IDENT_25 ) ; IDENT_30 . METHOD_16 ( IDENT_23 ) ; IDENT_30 . METHOD_17 ( IDENT_31 ) ; IDENT_30 . METHOD_18 ( IDENT_32 ) ; org . apache . IDENT_1 . common . protocol . body . IDENT_33 IDENT_34 = new org . apache . IDENT_1 . common . protocol . body . METHOD_19 ( ) ; IDENT_34 . METHOD_20 ( IDENT_35 ) ; IDENT_34 . METHOD_21 ( IDENT_36 ) ; final byte [ ] body = IDENT_34 . encode ( IDENT_32 ) ; final int IDENT_37 = org . apache . IDENT_1 . common . IDENT_38 . METHOD_22 ( body ) ; IDENT_30 . METHOD_23 ( IDENT_37 ) ; final java . util . concurrent . IDENT_39 IDENT_40 = new java . util . concurrent . METHOD_24 ( IDENT_27 . size ( ) ) ; for ( final java . lang . String IDENT_41 : IDENT_27 ) { IDENT_42 . execute ( new java . lang . METHOD_25 ( ) { @ org . apache . IDENT_1 . IDENT_16 . out . Override public void run ( ) { try { org . apache . IDENT_1 . common . IDENT_4 . IDENT_21 result = METHOD_26 ( IDENT_41 , IDENT_43 , IDENT_44 , IDENT_30 , body ) ; if ( result != null ) { IDENT_22 . add ( result ) ; } org . apache . IDENT_1 . IDENT_16 . out . IDENT_45 . log . info ( STRING_1 , IDENT_26 , IDENT_41 ) ; } catch ( java . lang . Exception e ) { org . apache . IDENT_1 . IDENT_16 . out . IDENT_45 . log . warn ( STRING_2 , IDENT_41 , e ) ; } finally { IDENT_40 . METHOD_27 ( ) ; } } } ) ; } try { IDENT_40 . METHOD_28 ( IDENT_44 , TimeUnit . IDENT_19 ) ; } catch ( java . lang . IDENT_46 e ) { } } return IDENT_22 ; }
org . junit . Assert . assertEquals ( 2 , IDENT_22 . size ( ) )