Removed unused ArrayBlockingQueue since listeners are single-threaded