@Override public void emit(AlertStreamEvent event){
  try {
    queue.put(event);
  }
 catch (  InterruptedException e) {
    LOG.error(e.getMessage(),e);
  }
}

@ Override public void emit ( AlertStreamEvent event ) { try { queue . put ( event ) ; } catch ( InterruptedException e ) { LOG . error ( e . getMessage ( ) , e ) ; } }
emit method can be called in multi - thread .
