| | |
|---|
| | | return BindingBuilder.bind(orderBonusQueue()).to(orderBonusExchange()).with(RabbitQueueEnum.ORDER_BONUS.getRoute()); |
|---|
| | | } |
|---|
| | | //订单分红 end |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 矩阵节点 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @Bean |
|---|
| | | public DirectExchange matrixTreeExchange() { |
|---|
| | | return new DirectExchange(RabbitQueueEnum.MATRIX_TREE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue matrixTreeQueue() { |
|---|
| | | return new Queue(QueueConstants.MATRIX_TREE); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding matrixTreeBind() { |
|---|
| | | return BindingBuilder.bind(matrixTreeQueue()).to(matrixTreeExchange()).with(RabbitQueueEnum.MATRIX_TREE.getRoute()); |
|---|
| | | } |
|---|
| | | } |
|---|
