初始化空投队列

src/main/java/com/xs/core/config/mq/RabbitMQConfig.java

@@ -77,4 +77,22 @@ public class RabbitMQConfig {
                 .noargs();
     }
 
+    @Bean
+    public Queue airdropQueue() {
+        return new Queue(AIRDROP_QUEUE, true, false, false);
+    }
+
+
+    @Bean
+    public DirectExchange airdropExchange() {
+        return new DirectExchange(AIRDROP_EXCHANGE, true, false);
+    }
+
+    @Bean
+    public Binding bindingAirdrop() {
+        return BindingBuilder.bind(airdropQueue())
+                .to(airdropExchange())
+                .with(AIRDROP_QUEUE);
+    }
+
 }