| | |
|---|
| | | 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 com.matrix.system.wechart.templateMsg.Task.UniformMsgSentTask; |
|---|
| | | import org.springframework.beans.factory.annotation.Value; |
|---|
| | |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public RabiitMqTemplate rabiitMqTemplate() throws IOException { |
|---|
| | | |
|---|
| | | LogUtil.info("rabbitmq: {}, {}, {}, {}", host, port, username, password); |
|---|
| | | RabiitMqTemplate rabiitMqTemplate = RabiitMqTemplateFactory.buildTemplate(host, port, username, password); |
|---|
| | | |
|---|
| | | //声明一个交换机 |
|---|
