public List<BriefMQMessage> queryMessage(QueryMessageRequest request) {
        Preconditions.expectNotBlank(request.getGroupId(), ErrorCodeEnum.GROUP_ID_IS_EMPTY);
        Preconditions.expectNotBlank(request.getStreamId(), ErrorCodeEnum.STREAM_ID_IS_EMPTY);
        Map<String, Object> requestMap = JsonUtils.parseObject(request,
                new TypeReference<Map<String, Object>>() {
                });
        requestMap.entrySet().removeIf(entry -> Objects.isNull(entry.getValue()));
        Response<List<BriefMQMessage>> response = ClientUtils.executeHttpCall(
                inlongStreamApi.listMessages(requestMap));
        ClientUtils.assertRespSuccess(response);
        return response.getData();
    }
Converts a json string to a streamFields

@param method the method for the field information: json or sql
@param statement the statement for the field information
@return list of stream field
inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java