Make async publishing & consuming integration test more resillent to race conditions.