class CloudEventSubscribeBeanExtractor implements BeanExtractor<CloudEventSubscribe> {

    @Override
    public void doExtract(BeanWrap bw, Method method, CloudEventSubscribe anno) {<FILL_FUNCTION_BODY>}
}

        if (CloudClient.event() == null) {
            throw new IllegalArgumentException("Missing CloudEventService component");
        }

        Parameter[] args = method.getParameters();
        if (args.length != 1) {
            throw new IllegalArgumentException("Missing CloudEventSubscriber method need one parameter");
        }

        Class<?> entityClz = args[0].getType();

        CloudEvent anno2 = entityClz.getAnnotation(CloudEvent.class);

        if (anno2 == null) {
            throw new IllegalArgumentException("The entity is missing (@CloudEvent) annotations: " + this.getClass().getName());
        }

        //支持${xxx}配置
        String topic2 = Solon.cfg().getByParse(Utils.annoAlias(anno2.value(), anno2.topic()));
        //支持${xxx}配置
        String group2 = Solon.cfg().getByParse(anno2.group());

        CloudEventMethodProxy hadnler2 = new CloudEventMethodProxy(bw, method, entityClz);

        CloudManager.register(anno2, hadnler2);
        CloudClient.event().attention(anno2.level(), anno2.channel(), group2, topic2, anno2.tag(), anno2.qos(), hadnler2);
    
<no_super_class>