MQ中Message<DomainEvent>增加入参获取方式

[wangyuheng]

背景

MQ通过Message传递参数，但是无法快速获取入参。

方案

通过ExecutionInput解析参数较为复杂

    private Optional<Argument> getArgumentByName(ExecutionInput input, String name) {
        return parser.parseDocument(input.getQuery())
                .getDefinitionsOfType(OperationDefinition.class).stream()
                .map(OperationDefinition::getSelectionSet)
                .map(it -> it.getSelectionsOfType(Field.class))
                .filter(Objects::nonNull)
                .flatMap(Collection::stream)
                .map(Field::getArguments)
                .filter(Objects::nonNull)
                .flatMap(Collection::stream)
                .filter(it -> it.getName().equals(name))
                .findAny();
    }

考虑通过新属性传递，或者提供相关工具扩展

验收

MQ consumer 可以快速获取入参