METHOD_0 ( ) { org . apache . IDENT_0 . Context context = new org . apache . IDENT_0 . Context ( ) ; java . io . File IDENT_1 = new java . io . File ( ( ( IDENT_2 . getAbsolutePath ( ) ) + STRING_0 ) ) ; com . google . common . io . IDENT_3 . write ( STRING_1 . getBytes ( ) , IDENT_1 ) ; java . io . File IDENT_4 = new java . io . File ( ( ( IDENT_2 . getAbsolutePath ( ) ) + STRING_2 ) ) ; com . google . common . io . IDENT_3 . write ( new byte [ 0 ] , IDENT_4 ) ; context . put ( IDENT_5 . IDENT_6 , IDENT_2 . getAbsolutePath ( ) ) ; org . apache . IDENT_0 . conf . IDENT_7 . METHOD_1 ( org . apache . IDENT_0 . source . IDENT_8 . source , context ) ; org . apache . IDENT_0 . source . IDENT_8 . source . start ( ) ; java . lang . Thread . sleep ( 10 ) ; for ( int i = 0 ; i < 2 ; i ++ ) { org . apache . IDENT_0 . IDENT_9 IDENT_10 = org . apache . IDENT_0 . source . IDENT_8 . channel . METHOD_2 ( ) ; IDENT_10 . METHOD_3 ( ) ; org . apache . IDENT_0 . IDENT_11 e = org . apache . IDENT_0 . source . IDENT_8 . channel . METHOD_4 ( ) ; IDENT_10 . commit ( ) ; IDENT_10 . close ( ) ; } org . apache . IDENT_0 . IDENT_9 IDENT_10 = org . apache . IDENT_0 . source . IDENT_8 . channel . METHOD_2 ( ) ; IDENT_10 . METHOD_3 ( ) ; "<AssertPlaceHolder>" ; IDENT_10 . commit ( ) ; IDENT_10 . close ( ) ; org . apache . IDENT_0 . source . IDENT_8 . source . METHOD_5 ( ) ; } METHOD_4 ( ) { com . google . common . base . IDENT_12 . METHOD_6 ( ( ( queue ) != null ) , STRING_3 ) ; IDENT_13 . METHOD_7 ( ) ; try { org . apache . IDENT_0 . IDENT_11 e = queue . METHOD_8 ( IDENT_14 , TimeUnit . IDENT_15 ) ; IDENT_13 . METHOD_9 ( 1 ) ; IDENT_13 . METHOD_10 ( queue . size ( ) ) ; return e ; } catch ( java . lang . IDENT_16 ex ) { throw new org . apache . IDENT_0 . METHOD_11 ( STRING_4 , ex ) ; } }
org . junit . Assert . assertNull ( org . apache . IDENT_0 . source . IDENT_8 . channel . METHOD_4 ( ) )