| | |
|---|
| | | SalesOrderTask SalesOrderTask() { |
|---|
| | | return new SalesOrderTask(); |
|---|
| | | } |
|---|
| | | @Bean |
|---|
| | | SalesOrderRefundTask SalesOrderRefundTask() { |
|---|
| | | return new SalesOrderRefundTask(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | TemplateMsgTask TemplateMsgTask(){ |
|---|
| | |
|---|
| | | taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.SEND_TEMPLATE_MSG + evn,MQTaskRouting.SEND_TEMPLATE_MSG + evn, TemplateMsgTask())); |
|---|
| | | taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.ORDER_OUT_SOTORE + evn,MQTaskRouting.ORDER_OUT_SOTORE + evn, OrderOutSotoreTask())); |
|---|
| | | taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG + evn,MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG + evn, UniformMsgSentTask())); |
|---|
| | | taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.SHOP_ORDER_REFUND + evn,MQTaskRouting.SHOP_ORDER_REFUND + evn, SalesOrderRefundTask())); |
|---|
| | | |
|---|
| | | //不同任务在不同的队列，但是routingKey一样则可以收到生产者消息 |
|---|
| | | taskList.add(new MqTask(MQ_EXCHANGE_TOPIC + evn, MQTaskRouting.CREATE_ORDER + evn,MQTaskRouting.CREATE_ORDER + evn,SalesOrderTask())); |
|---|
