@Override
	public Object postProcessAfterInitialization(Object bean, String beanName)
			throws BeansException {
		Stream.of(RocketMQBeanContainerCache.getClassAry()).forEach(clazz -> {
			if (clazz.isAssignableFrom(bean.getClass())) {
				RocketMQBeanContainerCache.putBean(beanName, bean);
			}
		});
		return bean;
	}
find RocketMQ bean by annotations.

@author junboXiang
spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/custom/RocketMQConfigBeanPostProcessor.java