METHOD_0 ( ) { org . eclipse . IDENT_0 . common . util . IDENT_1 < java . lang . String , java . lang . String > attributes = IDENT_2 . METHOD_1 ( ) ; attributes . put ( IDENT_3 . IDENT_4 , STRING_0 ) ; attributes . put ( IDENT_3 . IDENT_5 , IDENT_6 . METHOD_2 ( ) ) ; attributes . put ( IDENT_3 . IDENT_7 , IDENT_8 . IDENT_9 ) ; IDENT_2 . METHOD_3 ( STRING_1 ) ; java . util . concurrent . IDENT_10 IDENT_11 = null ; try { IDENT_11 = java . util . concurrent . IDENT_12 . METHOD_4 ( ) ; java . util . concurrent . IDENT_13 future = IDENT_11 . METHOD_5 ( new java . lang . METHOD_6 ( ) { public void run ( ) { try { org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_7 ( IDENT_2 ) ; "<AssertPlaceHolder>" ; } catch ( org . talend . repository . IDENT_14 . exceptions . IDENT_16 e ) { org . junit . Assert . fail ( e . getMessage ( ) ) ; } } } ) ; while ( true ) { if ( ( future . get ( ) ) == null ) { break ; } java . lang . Thread . sleep ( 1000 ) ; } } catch ( java . lang . Exception exception ) { org . junit . Assert . fail ( exception . getMessage ( ) ) ; } finally { if ( IDENT_11 != null ) { IDENT_11 . METHOD_8 ( ) ; } } } METHOD_7 ( org . talend . repository . model . IDENT_14 . IDENT_17 ) { boolean IDENT_18 = true ; final java . lang . IDENT_19 IDENT_20 = org . talend . repository . IDENT_14 . factory . IDENT_21 . METHOD_9 ( connection ) ; java . lang . IDENT_19 IDENT_22 = java . lang . Thread . METHOD_10 ( ) . METHOD_11 ( ) ; java . lang . Thread . METHOD_10 ( ) . METHOD_12 ( IDENT_20 ) ; java . lang . Object IDENT_23 = null ; try { boolean IDENT_24 = java . lang . Boolean . valueOf ( connection . METHOD_1 ( ) . get ( IDENT_3 . IDENT_4 ) ) ; if ( IDENT_24 && ( org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_13 ( connection ) ) ) { java . lang . String IDENT_25 = org . apache . commons . lang . StringUtils . METHOD_14 ( connection . METHOD_1 ( ) . get ( IDENT_3 . IDENT_26 ) ) ; java . lang . String IDENT_27 = org . apache . commons . lang . StringUtils . METHOD_14 ( connection . METHOD_1 ( ) . get ( IDENT_3 . IDENT_28 ) ) ; java . lang . String IDENT_29 = org . apache . commons . lang . StringUtils . METHOD_14 ( connection . METHOD_1 ( ) . get ( IDENT_3 . IDENT_30 ) ) ; if ( connection . METHOD_15 ( ) ) { org . talend . IDENT_31 . core . model . utils . IDENT_0 . IDENT_32 . IDENT_33 IDENT_34 = org . talend . metadata . IDENT_35 . ui . utils . IDENT_36 . METHOD_16 ( connection ) ; if ( IDENT_34 != null ) { IDENT_25 = org . talend . core . model . utils . IDENT_37 . METHOD_17 ( IDENT_34 , IDENT_25 ) ; IDENT_27 = org . talend . core . model . utils . IDENT_37 . METHOD_17 ( IDENT_34 , IDENT_27 ) ; IDENT_29 = org . talend . core . model . utils . IDENT_37 . METHOD_17 ( IDENT_34 , IDENT_29 ) ; } } else { IDENT_27 = connection . getValue ( IDENT_27 , false ) ; } if ( java . lang . Thread . METHOD_10 ( ) . METHOD_18 ( ) ) { throw new java . lang . METHOD_19 ( ) ; } java . lang . Object IDENT_38 = org . talend . repository . IDENT_14 . IDENT_39 . IDENT_40 . METHOD_20 ( STRING_2 , STRING_3 , new java . lang . Object [ ] { IDENT_25 , IDENT_27 } , IDENT_20 , java . lang . String . class , java . lang . String . class ) ; org . talend . repository . IDENT_14 . IDENT_39 . IDENT_40 . METHOD_20 ( STRING_4 , STRING_5 , new java . lang . Object [ ] { IDENT_29 , IDENT_38 } , IDENT_20 , java . lang . String . class , java . lang . Class . METHOD_21 ( STRING_6 , true , IDENT_20 ) ) ; return IDENT_18 ; } if ( java . lang . Thread . METHOD_10 ( ) . METHOD_18 ( ) ) { throw new java . lang . METHOD_19 ( ) ; } final java . lang . Object db = org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_22 ( connection ) ; IDENT_23 = db ; if ( IDENT_24 ) { org . talend . repository . IDENT_14 . IDENT_39 . IDENT_40 . METHOD_23 ( db , STRING_7 , new java . lang . Object [ 0 ] ) ; } else { if ( org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_24 ( connection ) ) { org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_25 ( db , IDENT_20 , connection ) ; } else { new org . talend . repository . IDENT_14 . db . util . neo4j . METHOD_26 ( ) { @ org . talend . repository . IDENT_14 . db . util . neo4j . Override MOD_0 java . lang . Object run ( ) throws org . talend . repository . IDENT_14 . db . util . neo4j . Exception { org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_25 ( db , IDENT_20 , connection ) ; return null ; } } . execute ( db ) ; } } } catch ( java . lang . Exception e ) { IDENT_18 = false ; org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_27 ( ) ; if ( e instanceof java . lang . METHOD_19 ) { throw new org . talend . repository . IDENT_14 . exceptions . METHOD_28 ( org . talend . repository . IDENT_14 . IDENT_41 . IDENT_42 . getString ( STRING_8 ) , e ) ; } else { throw new org . talend . repository . IDENT_14 . exceptions . METHOD_28 ( org . talend . repository . IDENT_14 . IDENT_41 . IDENT_42 . getString ( STRING_9 ) , e ) ; } } finally { if ( IDENT_23 != null ) { org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_29 ( IDENT_23 ) ; } java . lang . Thread . METHOD_10 ( ) . METHOD_12 ( IDENT_22 ) ; } return IDENT_18 ; }
org . junit . Assert . assertTrue ( org . talend . repository . IDENT_14 . db . util . neo4j . IDENT_15 . METHOD_7 ( IDENT_2 ) )