METHOD_0 ( ) { org . mockito . Mockito . METHOD_1 ( new java . lang . RuntimeException ( ) ) . when ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . task ) . init ( ) ; com . streamsets . IDENT_0 . IDENT_1 . IDENT_3 IDENT_1 = new com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_2 ( ) ; "<AssertPlaceHolder>" ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_4 , org . mockito . Mockito . times ( 1 ) ) . METHOD_3 ( ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_5 , org . mockito . Mockito . times ( 1 ) ) . log ( org . mockito . Mockito . any ( org . IDENT_6 . IDENT_7 . class ) ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_8 , org . mockito . Mockito . times ( 1 ) ) . log ( org . mockito . Mockito . any ( org . IDENT_6 . IDENT_7 . class ) ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . task , org . mockito . Mockito . times ( 1 ) ) . init ( ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . runtime , org . mockito . Mockito . times ( 0 ) ) . METHOD_4 ( org . mockito . Mockito . any ( com . streamsets . IDENT_0 . IDENT_1 . Thread . class ) ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . task , org . mockito . Mockito . times ( 0 ) ) . run ( ) ; org . mockito . Mockito . verify ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_2 . runtime , org . mockito . Mockito . times ( 0 ) ) . METHOD_5 ( org . mockito . Mockito . any ( com . streamsets . IDENT_0 . IDENT_1 . Thread . class ) ) ; } METHOD_6 ( ) { com . streamsets . IDENT_0 . security . IDENT_9 IDENT_10 ; org . IDENT_6 . IDENT_7 log = null ; try { final com . streamsets . IDENT_0 . task . IDENT_11 task = this . task ; IDENT_12 . get ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_13 . class ) . METHOD_3 ( ) ; log = org . IDENT_6 . IDENT_14 . METHOD_7 ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_15 . class ) ; log . info ( STRING_0 1 ) ; IDENT_12 . get ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_16 . class ) . log ( log ) ; log . info ( STRING_0 1 ) ; com . streamsets . IDENT_0 . IDENT_1 . IDENT_17 IDENT_8 = IDENT_12 . get ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_17 . class ) ; IDENT_8 . log ( log ) ; log . info ( STRING_0 1 ) ; com . streamsets . IDENT_0 . util . Configuration configuration = IDENT_12 . get ( com . streamsets . IDENT_0 . util . Configuration . class ) ; if ( ( java . lang . System . METHOD_8 ( ) ) != null ) { if ( configuration . get ( IDENT_18 , IDENT_19 ) ) { java . lang . System . METHOD_9 ( new com . streamsets . IDENT_0 . security . METHOD_10 ( IDENT_8 , configuration ) ) ; } log . info ( STRING_1 , java . lang . System . getProperty ( STRING_0 8 ) , java . lang . System . METHOD_8 ( ) . getClass ( ) . getName ( ) ) ; } else { log . warn ( STRING_0 ) ; } log . info ( STRING_0 1 ) ; log . info ( STRING_2 ) ; java . net . IDENT_20 . METHOD_11 ( new com . streamsets . IDENT_0 . IDENT_1 . METHOD_12 ( ) ) ; IDENT_10 = new com . streamsets . IDENT_0 . security . METHOD_13 ( IDENT_12 . get ( com . streamsets . IDENT_0 . IDENT_1 . IDENT_17 . class ) , configuration ) ; IDENT_10 . METHOD_14 ( ) ; log . info ( STRING_0 1 ) ; log . info ( STRING_0 7 , IDENT_10 . METHOD_15 ( ) . METHOD_16 ( ) ) ; if ( IDENT_10 . METHOD_15 ( ) . METHOD_16 ( ) ) { log . info ( STRING_0 2 , IDENT_10 . METHOD_15 ( ) . METHOD_17 ( ) ) ; log . info ( STRING_0 3 , IDENT_10 . METHOD_15 ( ) . METHOD_18 ( ) ) ; } try { boolean IDENT_21 = ( javax . crypto . IDENT_22 . METHOD_19 ( STRING_3 ) ) >= INT_0 ; log . info ( STRING_4 , IDENT_21 ) ; } catch ( java . security . IDENT_23 ex ) { log . info ( STRING_5 ) ; } log . info ( STRING_0 1 ) ; if ( configuration . get ( STRING_6 , false ) ) { log . warn ( STRING_7 ) ; } log . info ( STRING_2 ) ; final org . IDENT_6 . IDENT_7 IDENT_24 = log ; final com . streamsets . IDENT_0 . IDENT_1 . IDENT_25 . IDENT_26 IDENT_27 = new com . streamsets . IDENT_0 . IDENT_1 . IDENT_25 . METHOD_20 ( ) ; final java . util . concurrent . IDENT_28 IDENT_29 = java . util . concurrent . IDENT_30 . METHOD_21 ( 1 ) ; java . security . IDENT_31 < java . lang . IDENT_32 > action = ( ) -> { task . init ( ) ; java . lang . Thread IDENT_33 = new java . lang . Thread ( STRING_0 6 ) { @ java . lang . Override public void run ( ) { IDENT_24 . debug ( STRING_8 ) ; task . METHOD_22 ( ) ; } } ; METHOD_23 ( ) . METHOD_4 ( IDENT_33 ) ; IDENT_12 . get ( . class ) . METHOD_24 ( new com . streamsets . IDENT_0 . IDENT_1 . METHOD_25 ( IDENT_24 , task , IDENT_27 ) ) ; if ( ( IDENT_34 ) != null ) { IDENT_29 . METHOD_26 ( ( ) -> { try { if ( IDENT_34 . call ( ) ) { task . METHOD_22 ( ) ; } } catch ( e ) { IDENT_24 . error ( STRING_0 0 , com . streamsets . IDENT_0 . IDENT_1 . e ) ; throw new < com . streamsets . IDENT_0 . IDENT_1 . e > java . lang . RuntimeException ( ) ; } } , 1 , 1 , TimeUnit . IDENT_35 ) ; } task . run ( ) ; task . METHOD_27 ( ) ; IDENT_29 . METHOD_28 ( ) ; try { METHOD_23 ( ) . METHOD_5 ( IDENT_33 ) ; } catch ( IDENT_36 ) { } IDENT_24 . debug ( STRING_9 ) ; return null ; } ; com . streamsets . IDENT_0 . security . IDENT_37 . METHOD_29 ( IDENT_10 . METHOD_30 ( ) , action ) ; return IDENT_27 . METHOD_31 ( ) ; } catch ( java . lang . Throwable ex ) { if ( log != null ) { log . error ( STRING_0 4 , ex . toString ( ) , ex ) ; } System . out . println ( ) ; System . out . METHOD_32 ( com . streamsets . pipeline . api . impl . Utils . format ( STRING_0 4 , ex . toString ( ) ) ) ; System . out . METHOD_32 ( STRING_0 5 ) ; System . out . println ( ) ; System . err . println ( ) ; ex . printStackTrace ( System . err ) ; System . err . println ( ) ; return 1 ; } }
org . junit . Assert . assertEquals ( 1 , IDENT_1 . METHOD_6 ( ) )