@ Override public void onEvent ( Map < String , String > param ) throws SubscriberException { try { addToIndex ( param ) ; } catch ( Exception e ) { throw new SubscriberException ( "Fail to add log to solr" + e . getMessage ( ) ) ; } }
Method to fire for incoming events