var messageQueue = MemoryMessageQueue();
await messageQueue.open('123');  // correlationId = "123"