basic monitoring for async context queues, cleanup of async context
queues upon error and timeout, more unit test