let messageQueue = new MemoryMessageQueue();
await messageQueue.open(ctx)