Future<AmqpMessage> waitForReply(String correlationId) async { final completer = Completer<AmqpMessage>(); _replyCompleter[correlationId] = completer; return await completer.future; }