package com.ks.lucky.config;
|
|
import com.ks.lucky.util.mq.consumer.AcitivtyConsumer;
|
import com.ks.lucky.util.mq.consumer.AcitivtyDrawnRecieveOutDateConsumer;
|
import com.ks.lucky.utils.mq.CMQConsumeRunner;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
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 activityConsumer() {
|
CMQConsumeRunner runner = new AcitivtyConsumer();
|
return runner;
|
}
|
|
@Bean(initMethod = "start", destroyMethod = "destroy")
|
public CMQConsumeRunner recieveOutDateConsumer() {
|
CMQConsumeRunner runner = new AcitivtyDrawnRecieveOutDateConsumer();
|
return runner;
|
}
|
|
|
}
|
