METHOD_0 ( ) { com . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 server = METHOD_1 ( STRING_0 ) ; com . IDENT_0 . IDENT_1 . api . IDENT_4 . IDENT_5 IDENT_4 = new com . IDENT_0 . IDENT_1 . IDENT_4 . METHOD_2 ( STRING_1 , server . METHOD_3 ( ) ) ; java . util . concurrent . atomic . IDENT_6 result = new java . util . concurrent . atomic . METHOD_4 ( true ) ; java . util . concurrent . atomic . IDENT_7 IDENT_8 = new java . util . concurrent . atomic . METHOD_5 ( ( - 1 ) ) ; IDENT_9 . METHOD_6 ( new com . IDENT_0 . IDENT_1 . concurrent . METHOD_7 ( ) { @ com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Override MOD_0 void METHOD_8 ( ) throws com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Exception { com . IDENT_0 . IDENT_1 . redis . core . IDENT_12 . IDENT_13 . IDENT_14 command = new com . IDENT_0 . IDENT_1 . redis . core . IDENT_12 . IDENT_13 . METHOD_9 ( IDENT_15 . METHOD_10 ( new com . IDENT_0 . IDENT_1 . IDENT_4 . METHOD_2 ( STRING_2 , METHOD_11 ( ) ) ) , IDENT_9 , com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . IDENT_17 ) ; command . execute ( ) ; } } , METHOD_12 ( 1000 , INT_0 ) , com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . IDENT_17 , TimeUnit . IDENT_18 ) ; IDENT_9 . METHOD_13 ( new com . IDENT_0 . IDENT_1 . concurrent . METHOD_7 ( ) { @ com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Override MOD_0 void METHOD_8 ( ) throws com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Exception { com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . IDENT_19 command = new com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . METHOD_14 ( IDENT_15 . METHOD_10 ( IDENT_4 ) , IDENT_9 , com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . IDENT_17 ) ; command . future ( ) . METHOD_15 ( new com . IDENT_0 . IDENT_1 . api . command . IDENT_20 < java . lang . String > ( ) { @ com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Override public void METHOD_16 ( com . IDENT_0 . IDENT_1 . api . command . IDENT_21 < java . lang . String > IDENT_22 ) throws com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . Exception { long IDENT_23 = IDENT_8 . METHOD_17 ( java . lang . System . currentTimeMillis ( ) ) ; try { METHOD_18 ( IDENT_23 ) ; } catch ( java . lang . Exception e ) { logger . error ( STRING_3 , e ) ; result . set ( false ) ; } } } ) ; command . execute ( ) ; } } , 0 , com . IDENT_0 . IDENT_1 . redis . IDENT_10 . IDENT_11 . IDENT_16 . IDENT_17 , TimeUnit . IDENT_18 ) ; sleep ( ( 10 * 1000 ) ) ; "<AssertPlaceHolder>" ; } get ( ) { METHOD_19 ( ) ; java . lang . Throwable IDENT_24 = METHOD_20 ( ) ; if ( METHOD_20 == null ) { return METHOD_21 ( ) ; } if ( METHOD_20 instanceof com . IDENT_0 . IDENT_1 . command . IDENT_25 ) { throw ( ( com . IDENT_0 . IDENT_1 . command . IDENT_25 ) ( METHOD_20 ) ) ; } throw new com . IDENT_0 . IDENT_1 . command . METHOD_22 ( METHOD_20 ) ; }
org . junit . Assert . assertTrue ( result . get ( ) )