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