await messageQueue.close('123');    // correlationId = "123"