@ Override public void onEvent ( Object event , long sequence , boolean endOfBatch ) throws Exception { if ( event == null ) { return ; } handleEvent ( event , endOfBatch ) ; }
This function need to be implements