Browse Source

修改rabbitMq.server.ip为内网端口,增加Basic常量FUNCTION_THIRD_PARTY_PUSH_JIARAN

ZhangNing 5 months ago
parent
commit
3cd19b3bec

+ 2 - 0
src/main/java/com/xyhy/jiaranmqttcluster/common/Basic.java

@@ -39,6 +39,8 @@ public class Basic {
 
 
     public static int FUNCTION_TIMELINE_CALLBACK=1071;
     public static int FUNCTION_TIMELINE_CALLBACK=1071;
 
 
+    public static int FUNCTION_THIRD_PARTY_PUSH_JIARAN=2001;
+
 
 
     public static String ONLINE = "1";
     public static String ONLINE = "1";
     public static String OFFLINE = "0";
     public static String OFFLINE = "0";

+ 1 - 1
src/main/java/com/xyhy/jiaranmqttcluster/common/rabbitmq/listening/Listen_thirdPartyPush_jiaran.java

@@ -21,7 +21,7 @@ public class Listen_thirdPartyPush_jiaran {
 
 
         String exchangeName = Common.getConfigByName("rabbitMq.server.TOMQTTSERVEREXCHANGE");
         String exchangeName = Common.getConfigByName("rabbitMq.server.TOMQTTSERVEREXCHANGE");
 //        String queueName = "mqtt."+ Common.FUNCTION_ADDORDER_CALLBACK;
 //        String queueName = "mqtt."+ Common.FUNCTION_ADDORDER_CALLBACK;
-        String queueName = Common.getConfigByName("rabbitMq.server.ip")+"."+ Basic.FUNCTION_GETCPINFO_CALLBACK;
+        String queueName = Common.getConfigByName("rabbitMq.server.ip")+"."+ Basic.FUNCTION_THIRD_PARTY_PUSH_JIARAN;
         String Topic = queueName;
         String Topic = queueName;
 
 
         try {
         try {

+ 1 - 1
src/main/resources/application.properties

@@ -45,7 +45,7 @@ charging.interface.api.url.status=debug
 #logging.level.root=error
 #logging.level.root=error
 
 
 #######rabbitMQ###########
 #######rabbitMQ###########
-rabbitMq.server.ip=39.98.84.232
+rabbitMq.server.ip=172.26.76.31
 rabbitMq.server.port=5673
 rabbitMq.server.port=5673
 rabbitMq.server.vHost=/
 rabbitMq.server.vHost=/
 rabbitMq.server.userName=rabbit
 rabbitMq.server.userName=rabbit