Mq 的生产消费代码

MQ的生产消费的代码：
实现消息的监听方法：

@Component
@RocketMQMessageListener(topic="${mq.topic.topic-archive-index}", consumerGroup = "arc_consumer_group")
public class MQArcIndexListener implements RocketMQListener<String> {
	
	@Autowired
	private ArcIndexService arcIndexService;
	
	@Autowired
	private IArcMqMsgService arcMqMsgService;
	
    @Override
    public void onMessage(String message) {
//        log.info("监听到消息：msg={}", message);
        try {
        	
        	arcIndexService.excute(message);
        	
        } catch(Exception e) {
        	log.error("arcIndexService excute fail.", e);
        	saveMsg(message);
        }
    }
    
    /**