提交

integrate-mq/src/main/java/com/pannk/config/FanoutRabbitMQConfig.java

@@ -41,10 +41,10 @@ public class FanoutRabbitMQConfig {
     }
     @Bean
     public Binding bindingFanoutBExchange(){
-        return BindingBuilder.bind(fanoutAQueue()).to(fanoutExchange());
+        return BindingBuilder.bind(fanoutBQueue()).to(fanoutExchange());
     }
     @Bean
     public Binding bindingFanoutCExchange(){
-        return BindingBuilder.bind(fanoutAQueue()).to(fanoutExchange());
+        return BindingBuilder.bind(fanoutCQueue()).to(fanoutExchange());
     }
 }

integrate-mq/src/main/java/com/pannk/listener/TopicReceiveListener.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Component;
  * @author wolf
  * @date 20-11-17
  */
-//@Component
+@Component
 public class TopicReceiveListener {
 
     /**

integrate-swagger/pom.xml

@@ -21,11 +21,20 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <!--<dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+            <version>2.9.2</version>
+        </dependency>-->
 
         <dependency>
             <groupId>com.github.xiaoymin</groupId>
             <artifactId>knife4j-spring-boot-starter</artifactId>
-            <!--在引用时请在maven中央仓库搜索2.X最新版本号-->
             <version>2.0.8</version>
         </dependency>
         <dependency>

integrate-swagger/src/main/java/com/pannk/config/Swagger2Config.java

 package com.pannk.config;
 
+import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import springfox.documentation.builders.ApiInfoBuilder;
@@ -14,6 +15,7 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2WebMvc;
 /**
  * Created by wolf on 20-11-30.
  */
+@EnableKnife4j
 @EnableSwagger2WebMvc
 @Configuration
 public class Swagger2Config {