fix producer so that it doesn't fail first time after reconnect.
fix consumer to properly re-register even after multiple reconnects