<dependency>
	    <groupId>com.acmtc</groupId>
	    <artifactId>acmtc-redismq</artifactId>
	    <version>1.0.1-RELEASE</version>
	</dependency>

redis-mq:
  maxErrorCount: 3                                # redisMQ consumer error count, greater than it will be discarded.
  config:
      corePoolSize: 10                            # Set the redisMQ consumer ThreadPoolExecutor's core pool size.
      maxPoolSize: 100                            # Set the redisMQ consumer ThreadPoolExecutor's maximum pool size.
      keepAliveSeconds: 120                       # Set the redisMQ consumer ThreadPoolExecutor's keep-alive seconds.
      queueCapacity: 2                            # Set the capacity for the redisMQ consumer ThreadPoolExecutor's BlockingQueue.
      allowCoreThreadTimeOut: false               # Specify whether to allow core threads to time out.
  consumer:
    topicMainSwitch: false                        # redisMQ customize whether all consuming listener will be opened,false for all opened,true for custuming below,default false
    switchList:                                   # redisMQ specific consumers customize
      - topic: channels                           # specific consumer name, same topic as annotation used in @RedisConsumerAnnotation
        topicSwitch: true                         # true for open listener, default false
      - topic: channel2
        topicSwitch: false
      - topic: apsToolsChannels
        topicSwitch: true

@Configuration
public class RedisConfig {
	/**
	 * 重写RedisAutoConfiguration当中生成RedisTemplate的方法，将泛型改为实际项目当中使用的类型，否则启动报错
	 * @param redisConnectionFactory
	 * @return
	 * @throws UnknownHostException
	 */
	@Bean
	@ConditionalOnMissingBean(name = "redisTemplate")
	public RedisTemplate<?, ?> redisTemplate(
			RedisConnectionFactory redisConnectionFactory)
					throws UnknownHostException {
		RedisTemplate<?, ?> template = new RedisTemplate<Serializable, Serializable>();
		template.setConnectionFactory(redisConnectionFactory);
		return template;
	}
	
}

@EntityScan("com.acmtc")
@SpringBootApplication(scanBasePackages = {"com.acmtc"})

redisProducer.sendChannelMessage("testchannel", message);

@RedisConsumerAnnotation(topic = "testchannel")
public class ConsumerExample  extends RedisConsumer {
    public void onMessage(JSONObject json) {
        log.info("测试Consumer，接收消息：" + json);
    }
}