Adding connect/disconnect logic to MqService, updating e2e tests.