package com.ks.lucky.config;
|
|
import com.ks.lucky.util.mq.CMQConsumeRunner;
|
import com.ks.lucky.util.mq.consume.AcitivtyConsumer;
|
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
@Configuration
|
public class CMQConsumeConfig {
|
|
Logger log = LoggerFactory.getLogger(CMQConsumeConfig.class);
|
|
|
@Bean(initMethod = "start", destroyMethod = "destroy")
|
public CMQConsumeRunner xxlJobExecutor() {
|
CMQConsumeRunner runner = new AcitivtyConsumer();
|
return runner;
|
}
|
}
|
