''

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/config/rabbitmq/RabbitMQConfig.java

@@ -8,11 +8,11 @@ import org.springframework.context.annotation.Configuration;
 public class RabbitMQConfig {
 
     //心跳广播
-    public String infoFEventExchange = "Patrol_FInfo";
+    public String patrolFInfoExchange = "Patrol_FInfo";
 
     @Bean
     public FanoutExchange infoFExchange(){
-        return new FanoutExchange(infoFEventExchange,true,false);
+        return new FanoutExchange(patrolFInfoExchange,true,false);
     }
 
 

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/BaseAppInfoServiceImpl.java

@@ -84,7 +84,7 @@ public class BaseAppInfoServiceImpl extends AbstractCrudService<BaseAppInfoMappe
         map.put("deviceId",baseAppInfo.getDeviceId());
         map.put("userName",baseAppInfo.getUserName());
         map.put("createTime",baseAppInfo.getCreateTime());
-        rabbitTemplate.convertAndSend(rabbitMQConfig.infoFEventExchange,"",JSONObject.toJSONString(map));
+        rabbitTemplate.convertAndSend(rabbitMQConfig.patrolFInfoExchange,"",JSONObject.toJSONString(map));
 
         this.save(baseAppInfo);
         if (pushFlag.equals(1)){

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/listener/RabbitMQListener.java

@@ -16,7 +16,7 @@ public class RabbitMQListener {
     @RabbitHandler
     @RabbitListener(bindings = @QueueBinding(
             value = @Queue(),
-            exchange = @Exchange(value = "Info_FEvent",type = ExchangeTypes.FANOUT)
+            exchange = @Exchange(value = "Patrol_FInfo",type = ExchangeTypes.FANOUT)
     ))
     public void getData(Message message){
         try {