package com.ks.daylucky.config;
|
|
import com.ks.daylucky.util.mq.consumer.ActivityDrawnNotifyConsumer;
|
import com.ks.daylucky.util.mq.consumer.MsgConsumer;
|
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);
|
|
//订阅主题
|
// public CMQConsumeConfig(){
|
// CMQManager.getInstance();
|
//
|
// }
|
|
|
@Bean(initMethod = "start", destroyMethod = "destroy")
|
public CMQConsumeRunner msgConsumer() {
|
//订阅活动状态改变主题与助力主题
|
CMQConsumeRunner runner = new MsgConsumer();
|
return runner;
|
}
|
|
|
@Bean(initMethod = "start", destroyMethod = "destroy")
|
public CMQConsumeRunner drawnNorifyConsumer() {
|
//订阅活动状态改变主题与助力主题
|
CMQConsumeRunner runner = new ActivityDrawnNotifyConsumer();
|
return runner;
|
}
|
}
|
