添加耗材
This commit is contained in:
@@ -112,10 +112,13 @@ public class RabbitConfig {
|
|||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
public Binding bindingcons_Register() {
|
public Binding bindingcons_Register() {
|
||||||
return BindingBuilder.bind(queuePrint_Register()).to(printExchange_Register()).with(RabbitConstants.CONS_COLLECT_ROUTINGKEY_PUT);
|
return BindingBuilder.bind(queuecons_Register()).to(consExchange_Register()).with(RabbitConstants.CONS_COLLECT_ROUTINGKEY_PUT);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
public DirectExchange cons_msg_Exchange_Register() {
|
public DirectExchange cons_msg_Exchange_Register() {
|
||||||
return new DirectExchange(RabbitConstants.CONS_MSG_COLLECT_PUT);
|
return new DirectExchange(RabbitConstants.CONS_MSG_COLLECT_PUT);
|
||||||
@@ -128,7 +131,7 @@ public class RabbitConfig {
|
|||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
public Binding bindingcons_msg_Register() {
|
public Binding bindingcons_msg_Register() {
|
||||||
return BindingBuilder.bind(queuePrint_Register()).to(printExchange_Register()).with(RabbitConstants.CONS_MSG_COLLECT_ROUTINGKEY_PUT);
|
return BindingBuilder.bind(queuecons_msg_Register()).to(cons_msg_Exchange_Register()).with(RabbitConstants.CONS_MSG_COLLECT_ROUTINGKEY_PUT);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user