METHOD_0 ( ) { org . IDENT_0 . client . IDENT_1 IDENT_2 = IDENT_3 . METHOD_1 ( ) ; org . IDENT_0 . client . IDENT_4 pipeline = IDENT_3 . METHOD_2 ( IDENT_2 ) ; org . IDENT_0 . client . IDENT_5 IDENT_6 = new org . IDENT_0 . client . IDENT_5 . Builder ( pipeline , ( ( STRING_0 + ( METHOD_3 ( ) ) ) + STRING_1 ) ) . METHOD_4 ( ) . build ( IDENT_2 ) ; org . IDENT_0 . client . IDENT_7 IDENT_8 = new org . IDENT_0 . client . IDENT_7 . Builder ( pipeline ) . build ( IDENT_2 ) ; IDENT_6 . connect ( IDENT_2 , IDENT_8 ) ; org . IDENT_0 . client . IDENT_9 < java . lang . String > IDENT_10 = IDENT_8 . METHOD_5 ( IDENT_2 ) ; IDENT_2 . commit ( ) ; org . IDENT_0 . client . IDENT_1 IDENT_11 = pipeline . METHOD_1 ( ) ; IDENT_6 . METHOD_6 ( IDENT_11 ) ; org . IDENT_0 . client . IDENT_9 < java . lang . String > IDENT_12 = IDENT_8 . METHOD_5 ( IDENT_11 ) ; pipeline . METHOD_7 ( IDENT_11 ) ; IDENT_11 . commit ( ) ; "<AssertPlaceHolder>" ; } get ( ) { try { return future . get ( ) ; } catch ( java . lang . IDENT_13 e ) { throw new org . IDENT_0 . commons . exception . METHOD_8 ( e ) ; } catch ( java . util . concurrent . IDENT_14 e ) { if ( ( e . METHOD_9 ( ) ) instanceof org . IDENT_0 . client . internal . server . IDENT_15 ) { throw new org . IDENT_0 . client . METHOD_10 ( operation , ( ( org . IDENT_0 . client . internal . server . IDENT_15 ) ( e . METHOD_9 ( ) ) ) . METHOD_11 ( ) ) ; } else { throw new org . IDENT_0 . commons . exception . METHOD_8 ( e . METHOD_9 ( ) ) ; } } catch ( java . util . concurrent . IDENT_16 e ) { throw new org . IDENT_0 . client . METHOD_12 ( ) ; } }
org . junit . Assert . assertThat ( IDENT_10 . get ( ) , org . hamcrest . CoreMatchers . is ( IDENT_12 . get ( ) ) )