ad synchronize and asynchronous consumer + add mechanisms of reliability