Improving sync with broker. Works with one transport, not 100% safe with multiple transports yet (need a queue per transport in sync event handler processor)