[#41447155] Refactor message bus, create channel and exchange in connect method.