|  |  | 
 |  |  | import com.matrix.component.rabbitmq.MqTask; | 
 |  |  | import com.matrix.component.rabbitmq.RabiitMqTemplate; | 
 |  |  | import com.matrix.component.rabbitmq.RabiitMqTemplateFactory; | 
 |  |  | import com.matrix.core.tools.LogUtil; | 
 |  |  | import com.matrix.system.shopXcx.mqTask.*; | 
 |  |  | import org.springframework.beans.factory.annotation.Value; | 
 |  |  | import org.springframework.context.annotation.Bean; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Bean | 
 |  |  |     public RabiitMqTemplate rabiitMqTemplate() throws IOException { | 
 |  |  |  | 
 |  |  |         LogUtil.info("rabbitmq: {}, {}, {}, {}", host, port, username, password); | 
 |  |  |         RabiitMqTemplate rabiitMqTemplate = RabiitMqTemplateFactory.buildTemplate(host, port, username, password); | 
 |  |  |  | 
 |  |  |         //声明一个交换机 |