Function run 

pub async fn run<T: Transport + Send + Sync + 'static>(
    transport: T,
    options: ClientOptions,
    clean_start: bool,
    cmd_rx: Receiver<Command>,
    shutdown_rx: Receiver<()>,
    msg_tx: Sender<Message>,
    session: JournaledSession,
    store: Persistence,
    status_tx: Sender<ConnectionStatus>,
)