提交修改

api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java

@@ -74,7 +74,7 @@ public class RabbitConfig {
 
     // ----------------------------   定义exchange   ---------------------------------
     // 定义广播模式的延时交换机 无需绑定路由
-    @Bean
+    //@Bean
     FanoutExchange delayExchange(@Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) {
         Map<String, Object> args = new HashMap<String, Object>();
         args.put("x-delayed-type", "direct");
@@ -84,7 +84,7 @@ public class RabbitConfig {
     }
 
     // 绑定延时队列与交换机
-    @Bean
+    //@Bean
     public Binding delayPayBind(@Value("${eb.config.rabbitQueue.delayQueue}") String delay_queue_name,
                                 @Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) {
         return BindingBuilder

api-web/api-interface/src/main/resources/bootstrap-online.yml

@@ -49,7 +49,26 @@ spring:
     host: 172.16.5.230
     timeout: 5000
   rabbitmq:
-    host: 121.40.41.240
+    host: 172.16.5.230
     port: 5672
-    username: admin
-    password: XiIg37HKfQg2
+    username: user
+    password: dk_eP^#fkLf30
+    listener:
+      simple:
+        # 设置手动ack回复
+        acknowledge-mode: manual
+        retry:
+          # 开启重试机制
+          enabled: true
+          # 重试次数
+          max-attempts: 3
+          # 重试最大间隔时间
+          max-interval: 100000
+          # 重试初始间隔时间
+          initial-interval: 100
+          # 间隔时间因子
+          multiplier: 20
+    #设置消息发送回调
+    publisher-returns: true
+    publisher-confirm-type: simple
+    virtual-host: /