METHOD_0 ( ) { java . lang . System . setProperty ( STRING_0 , STRING_1 ) ; final org . apache . nifi . remote . client . IDENT_0 client = new org . apache . nifi . remote . client . IDENT_0 . Builder ( ) . url ( STRING_2 ) . METHOD_1 ( STRING_3 ) . METHOD_2 ( 10 ) . build ( ) ; try { for ( int i = 0 ; i < 1000 ; i ++ ) { final org . apache . nifi . remote . IDENT_1 transaction = client . METHOD_3 ( IDENT_2 . IDENT_3 ) ; "<AssertPlaceHolder>" ; org . apache . nifi . remote . protocol . IDENT_4 packet ; while ( true ) { packet = transaction . METHOD_4 ( ) ; if ( packet == null ) { break ; } final java . io . InputStream in = packet . METHOD_5 ( ) ; final long size = packet . METHOD_6 ( ) ; final byte [ ] IDENT_5 = new byte [ ( ( int ) ( size ) ) ] ; org . apache . nifi . stream . io . IDENT_6 . METHOD_7 ( in , IDENT_5 ) ; } transaction . METHOD_8 ( ) ; transaction . METHOD_9 ( ) ; } } finally { client . close ( ) ; } } METHOD_3 ( org . apache . nifi . remote . IDENT_2 ) { final int IDENT_7 = ( ( int ) ( config . METHOD_10 ( TimeUnit . IDENT_8 ) ) ) ; org . apache . nifi . remote . IDENT_9 IDENT_10 ; while ( ( IDENT_10 = IDENT_11 . METHOD_11 ( IDENT_12 ) ) != null ) { org . apache . nifi . remote . client . http . IDENT_13 . logger . debug ( STRING_4 , IDENT_10 ) ; final org . apache . nifi . remote . protocol . IDENT_14 IDENT_15 = new org . apache . nifi . remote . io . http . METHOD_12 ( ) ; final java . lang . String IDENT_16 = METHOD_13 ( IDENT_10 . METHOD_14 ( ) ) ; final java . lang . StringBuilder IDENT_17 = new java . lang . StringBuilder ( ) ; config . METHOD_15 ( ) . METHOD_16 ( ( url ) -> { if ( ( IDENT_17 . length ( ) ) > 0 ) { IDENT_17 . append ( STRING_5 ) ; IDENT_17 . append ( url ) ; } } ) ; final org . apache . nifi . remote . IDENT_18 IDENT_19 = new org . apache . nifi . remote . METHOD_17 ( IDENT_10 . METHOD_14 ( ) , IDENT_15 , IDENT_16 , IDENT_17 . toString ( ) ) ; final int IDENT_20 = ( ( int ) ( config . METHOD_18 ( TimeUnit . IDENT_8 ) ) ) ; java . lang . String IDENT_21 = config . METHOD_19 ( ) ; if ( org . apache . commons . lang3 . StringUtils . isEmpty ( IDENT_21 ) ) { IDENT_21 = IDENT_22 . METHOD_19 ( config . METHOD_20 ( ) , IDENT_12 ) ; if ( org . apache . commons . lang3 . StringUtils . isEmpty ( IDENT_21 ) ) { IDENT_19 . close ( ) ; throw new java . io . IOException ( ( STRING_6 + ( config . METHOD_20 ( ) ) ) ) ; } } final org . apache . nifi . remote . util . IDENT_23 IDENT_24 = new org . apache . nifi . remote . util . METHOD_21 ( config . METHOD_22 ( ) , config . METHOD_23 ( ) , config . METHOD_24 ( ) ) ; IDENT_24 . METHOD_25 ( IDENT_19 . METHOD_26 ( ) ) ; IDENT_24 . METHOD_27 ( IDENT_7 ) ; IDENT_24 . METHOD_28 ( IDENT_7 ) ; IDENT_24 . METHOD_29 ( config . METHOD_30 ( TimeUnit . IDENT_8 ) ) ; IDENT_24 . METHOD_31 ( config . METHOD_32 ( ) ) ; IDENT_24 . METHOD_33 ( config . METHOD_34 ( ) ) ; IDENT_24 . METHOD_35 ( config . METHOD_36 ( TimeUnit . IDENT_8 ) ) ; IDENT_24 . METHOD_37 ( config . METHOD_38 ( ) ) ; IDENT_24 . METHOD_39 ( config . METHOD_40 ( ) ) ; IDENT_24 . METHOD_41 ( config . METHOD_42 ( TimeUnit . IDENT_8 ) ) ; final java . lang . String IDENT_25 ; try { IDENT_25 = IDENT_24 . METHOD_43 ( IDENT_12 , IDENT_21 ) ; IDENT_15 . METHOD_44 ( IDENT_24 . METHOD_45 ( ) ) ; } catch ( final java . lang . Exception e ) { IDENT_24 . close ( ) ; org . apache . nifi . remote . client . http . IDENT_13 . logger . warn ( STRING_7 , IDENT_19 , e . toString ( ) ) ; IDENT_11 . METHOD_46 ( IDENT_19 , IDENT_20 ) ; if ( ( ( e instanceof org . apache . nifi . remote . exception . IDENT_26 ) || ( e instanceof org . apache . nifi . remote . exception . IDENT_27 ) ) || ( e instanceof org . apache . nifi . remote . exception . IDENT_28 ) ) { throw e ; } org . apache . nifi . remote . client . http . IDENT_13 . logger . debug ( STRING_8 ) ; continue ; } final java . lang . Integer IDENT_29 = IDENT_24 . METHOD_47 ( ) ; final org . apache . nifi . remote . protocol . http . IDENT_30 transaction = new org . apache . nifi . remote . protocol . http . METHOD_48 ( IDENT_29 , IDENT_19 , IDENT_12 , config . METHOD_34 ( ) , IDENT_21 , IDENT_20 , config . METHOD_24 ( ) ) { @ org . apache . nifi . remote . client . http . Override MOD_0 void close ( ) throws java . io . IOException { try { super . close ( ) ; } finally { IDENT_31 . remove ( this ) ; } } } ; try { transaction . METHOD_49 ( IDENT_24 , IDENT_25 ) ; } catch ( final java . lang . Exception e ) { transaction . error ( ) ; throw e ; } IDENT_31 . add ( transaction ) ; return transaction ; } org . apache . nifi . remote . client . http . IDENT_13 . logger . info ( STRING_9 ) ; return null ; }
org . junit . Assert . assertNotNull ( transaction )