METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; final int IDENT_1 = INT_0 ; final com . IDENT_2 . IDENT_3 . cluster . IDENT_4 IDENT_5 = new com . IDENT_2 . IDENT_3 . cluster . METHOD_1 ( STRING_1 ) ; final long offset = 12 ; final com . IDENT_2 . IDENT_3 . cluster . IDENT_6 IDENT_7 = new com . IDENT_2 . IDENT_3 . cluster . METHOD_2 ( 0 , STRING_2 ) ; final int IDENT_8 = INT_1 ; final byte [ ] data = com . IDENT_2 . IDENT_3 . utils . IDENT_9 . METHOD_3 ( IDENT_8 , new com . IDENT_2 . IDENT_3 . network . METHOD_4 ( IDENT_0 , IDENT_5 . METHOD_5 ( ) , STRING_3 . getBytes ( ) , null , 0 , 0 ) ) . array ( ) ; final com . IDENT_2 . IDENT_3 . client . consumer . IDENT_10 request = new com . IDENT_2 . IDENT_3 . client . consumer . METHOD_6 ( IDENT_7 , 0 , new com . IDENT_2 . IDENT_3 . client . consumer . METHOD_7 ( IDENT_0 , IDENT_5 , offset ) , IDENT_1 ) ; final com . IDENT_2 . IDENT_3 . client . consumer . IDENT_11 . IDENT_12 runner = this . IDENT_13 . new com . IDENT_2 . IDENT_3 . client . consumer . IDENT_11 . METHOD_8 ( ) ; org . easymock . EasyMock . expect ( this . consumer . METHOD_9 ( request , ( - 1 ) , null ) ) . andReturn ( new com . IDENT_2 . IDENT_3 . consumer . METHOD_10 ( IDENT_0 , data ) ) ; final java . util . concurrent . atomic . IDENT_14 < com . IDENT_2 . IDENT_3 . Message > msg = new java . util . concurrent . atomic . IDENT_14 < com . IDENT_2 . IDENT_3 . Message > ( ) ; org . easymock . EasyMock . expect ( this . consumer . METHOD_11 ( IDENT_0 ) ) . andReturn ( new com . IDENT_2 . IDENT_3 . client . consumer . METHOD_12 ( ) { @ com . IDENT_2 . IDENT_3 . client . consumer . Override public void METHOD_13 ( final com . IDENT_2 . IDENT_3 . Message message ) { org . junit . Assert . fail ( ) ; } @ com . IDENT_2 . IDENT_3 . client . consumer . Override public java . util . concurrent . IDENT_15 METHOD_14 ( ) { return null ; } } ) ; org . easymock . EasyMock . expect ( this . consumer . METHOD_15 ( IDENT_0 ) ) . andReturn ( new com . IDENT_2 . IDENT_3 . consumer . METHOD_16 ( ) { @ com . IDENT_2 . IDENT_3 . client . consumer . Override public boolean accept ( java . lang . String group , com . IDENT_2 . IDENT_3 . Message message ) { throw new java . lang . RuntimeException ( ) ; } } ) ; org . easymock . EasyMock . expect ( this . consumer . METHOD_17 ( ) ) . andReturn ( new com . IDENT_2 . IDENT_3 . client . consumer . METHOD_18 ( "test" ) ) ; org . easymock . EasyMock . replay ( this . consumer ) ; runner . METHOD_19 ( request ) ; org . easymock . EasyMock . verify ( this . consumer ) ; "<AssertPlaceHolder>" ; } METHOD_19 ( com . IDENT_2 . IDENT_3 . client . consumer . METHOD_6 ) { try { final com . IDENT_2 . IDENT_3 . consumer . METHOD_10 iterator = this . consumer . METHOD_9 ( request , ( - 1 ) , null ) ; final com . IDENT_2 . IDENT_3 . client . consumer . METHOD_12 listener = this . consumer . METHOD_11 ( request . METHOD_20 ( ) ) ; final com . IDENT_2 . IDENT_3 . consumer . METHOD_16 filter = this . consumer . METHOD_15 ( request . METHOD_20 ( ) ) ; this . METHOD_21 ( request , iterator , listener , filter , this . consumer . METHOD_17 ( ) . METHOD_22 ( ) ) ; } catch ( final com . IDENT_2 . IDENT_3 . exception . IDENT_16 e ) { this . METHOD_23 ( request ) ; this . METHOD_24 ( request , e ) ; } catch ( final java . lang . IDENT_17 e ) { this . METHOD_25 ( request ) ; } catch ( final java . lang . Throwable e ) { this . METHOD_23 ( request ) ; this . METHOD_24 ( request , e ) ; } }
org . junit . Assert . assertNull ( msg . get ( ) )