QueriesInvocationHandler.java 文件源码

private SourceId getSourceId(AnnotatedElement element) {
    SourceId sourceId = null;
    Optional<Annotation> sourceAnnotation = Stream.of(element.getAnnotations())
            .filter(a -> a.annotationType().isAnnotationPresent(RegisteredSourceIdProducer.class)).findFirst();

    if (sourceAnnotation.isPresent()) {
        RegisteredSourceIdProducer sourceIdProviderAnnotation = sourceAnnotation.get().annotationType()
                .getAnnotation(RegisteredSourceIdProducer.class);
        try {
            SourceIdProducer sourceIdProducer = sourceIdProviderAnnotation.value().newInstance();
            sourceId = sourceIdProducer.get(element, sourceAnnotation.get());
        } catch (Exception e) {
            throw new QueryProxyException("Problem with sourceId aquiring: can't find suitable constructor " + e,
                    e);
        }
    }
    return sourceId;
}