new Promise(() => messageQueue.listen(ctx, new MyMessageReceiver()));