listener and thread_safe_queue implementing