|
@@ -3,7 +3,6 @@ package com.chelvc.framework.rocketmq.config;
|
|
|
import java.util.Objects;
|
|
|
import java.util.concurrent.atomic.AtomicLong;
|
|
|
|
|
|
-import lombok.RequiredArgsConstructor;
|
|
|
import com.chelvc.framework.rocketmq.annotation.RocketMQConsumer;
|
|
|
import com.chelvc.framework.rocketmq.consumer.MultipleRocketMQListenerContainer;
|
|
|
import com.chelvc.framework.rocketmq.consumer.RocketMQListenerContainer;
|
|
@@ -11,11 +10,11 @@ import com.chelvc.framework.rocketmq.consumer.SingleRocketMQListenerContainer;
|
|
|
import com.chelvc.framework.rocketmq.interceptor.RocketMQListener;
|
|
|
import com.chelvc.framework.rocketmq.producer.DefaultRocketMQProducerFactory;
|
|
|
import com.chelvc.framework.rocketmq.producer.RocketMQProducerFactory;
|
|
|
+import lombok.RequiredArgsConstructor;
|
|
|
import org.apache.rocketmq.client.apis.ClientConfiguration;
|
|
|
import org.apache.rocketmq.client.apis.ClientServiceProvider;
|
|
|
import org.apache.rocketmq.client.apis.SessionCredentialsProvider;
|
|
|
import org.apache.rocketmq.client.apis.StaticSessionCredentialsProvider;
|
|
|
-import org.apache.rocketmq.client.apis.producer.ProducerBuilder;
|
|
|
import org.springframework.aop.framework.AopProxyUtils;
|
|
|
import org.springframework.beans.BeansException;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -52,8 +51,7 @@ public class RocketMQConfigurer implements ApplicationContextAware {
|
|
|
|
|
|
@Bean
|
|
|
public RocketMQProducerFactory producerFactory() {
|
|
|
- ProducerBuilder builder = this.provider().newProducerBuilder().setClientConfiguration(this.configuration());
|
|
|
- return new DefaultRocketMQProducerFactory(builder);
|
|
|
+ return new DefaultRocketMQProducerFactory(this.provider(), this.configuration());
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -76,13 +74,14 @@ public class RocketMQConfigurer implements ApplicationContextAware {
|
|
|
return multiple ? new MultipleRocketMQListenerContainer<>() : new SingleRocketMQListenerContainer<>();
|
|
|
});
|
|
|
RocketMQListenerContainer<T> container = applicationContext.getBean(name, RocketMQListenerContainer.class);
|
|
|
- container.initialize(applicationContext, this.provider(), this.configuration(), listener, annotation,
|
|
|
+ container.initialize(this.provider(), this.configuration(), applicationContext, listener, annotation,
|
|
|
this.properties);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@SuppressWarnings("unchecked")
|
|
|
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
|
|
|
+ // 注册消息监听器
|
|
|
applicationContext.getBeansOfType(RocketMQListener.class).values()
|
|
|
.forEach(listener -> this.registerListenerContainer(applicationContext, listener));
|
|
|
}
|