瀏覽代碼

写死mq通信的exchange和routingkey

lixing 3 年之前
父節點
當前提交
7105f6d1db

+ 0 - 1
AlarmDataStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmdata/feign/AlarmClientConfig.java

@@ -8,7 +8,6 @@ import com.alibaba.fastjson.support.config.FastJsonConfig;
 import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
 import org.springframework.beans.factory.ObjectFactory;
 import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
-import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.cloud.openfeign.support.ResponseEntityDecoder;
 import org.springframework.cloud.openfeign.support.SpringDecoder;
 import org.springframework.cloud.openfeign.support.SpringEncoder;

+ 1 - 5
AlarmDataStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmdata/mq/InstanceObjMessageSender.java

@@ -17,11 +17,7 @@ import org.springframework.stereotype.Component;
 @Slf4j
 @Component
 public class InstanceObjMessageSender extends MessageSender {
-    @Value("${alarm.obj.routingKey}")
-    private String routingKey;
-
-    @Autowired
-    private RabbitTemplate rabbitTemplate;
+    private static final String routingKey = "";
 
     /**
      * @description: 发送消息

+ 1 - 2
AlarmDataStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmdata/mq/MessageSender.java

@@ -16,8 +16,7 @@ import org.springframework.beans.factory.annotation.Value;
  **/
 @Slf4j
 public abstract class MessageSender {
-    @Value("${dmp.alarm.exchange}")
-    private String exchange;
+    private static final String exchange = "exchange-dmp";
 
     @Autowired
     private RabbitTemplate rabbitTemplate;