1234567891011121314151617181920212223242526272829 |
- package cn.com.ctop.callback.config;
- import com.xxl.mq.client.factory.impl.XxlMqSpringClientFactory;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.context.annotation.Bean;
- import org.springframework.stereotype.Component;
- @Component
- public class XxlMqConf {
- // ---------------------- param ----------------------
- @Value("${xxl.mq.admin.address}")
- private String adminAddress;
- @Value("${xxl.mq.accessToken}")
- private String accessToken;
- @Bean
- public XxlMqSpringClientFactory getXxlMqConsumer(){
- XxlMqSpringClientFactory xxlMqSpringClientFactory = new XxlMqSpringClientFactory();
- xxlMqSpringClientFactory.setAdminAddress(adminAddress);
- xxlMqSpringClientFactory.setAccessToken(accessToken);
- return xxlMqSpringClientFactory;
- }
- }
|