metaq spring

红太狼 2022-08-13 11:45 136阅读 0赞

# spring metaq #

spring bean 配置

使用

import java.util.Date;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.stereotype.Service;
    
    import com.taobao.metamorphosis.client.extension.spring.MessageBuilder;
    import com.taobao.metamorphosis.client.extension.spring.MetaqTemplate;
    
    @Service("topicService")
    public class TopicService { 
    
        @Autowired
        @Qualifier("metaqTemplate")
        private MetaqTemplate metaqTemplate;
    
        public MetaqTemplate getMetaqTemplate() {
            return metaqTemplate;
        }
    
        public void setMetaqTemplate(MetaqTemplate metaqTemplate) {
            this.metaqTemplate = metaqTemplate;
        }
    
        public void sendMsg(String topic, String msg) {
            try {
    
                metaqTemplate.send(MessageBuilder.withTopic(topic).withBody(new Date()));
    
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    
    }