声明Exchange

@@ -62,6 +62,8 @@ public class MqBeansResgister implements InitializingBean {
         this.rabbitAdmin = new RabbitAdmin(connectionFactory);
         //定义Exchange
         this.directExchange = new DirectExchange(exchange);
+        //声明exchange
+        rabbitAdmin.declareExchange(directExchange);
         //定义队列
         Collection<TableConfig> configs = tableConfigLoader.getTableConfigs();
         for (TableConfig tableConfig: configs){