|
@@ -1,6 +1,5 @@
|
|
|
package com.fdkk.sxz.other.mq;
|
|
|
|
|
|
-import com.fdkk.sxz.util.SpringContextUtil;
|
|
|
import org.springframework.amqp.core.*;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
@@ -14,39 +13,38 @@ import java.util.Map;
|
|
|
@Configuration
|
|
|
public class TopicRabbitConfig {
|
|
|
|
|
|
- private static String active=SpringContextUtil.getActiveProfile();
|
|
|
|
|
|
- public final static String CHANGE = "topic.chang."+active;
|
|
|
+ public final static String CHANGE = "topic.chang.uat";
|
|
|
//灯光预览
|
|
|
- public final static String LIGHT = "topic.light."+active;
|
|
|
+ public final static String LIGHT = "topic.light.uat";
|
|
|
|
|
|
////图片渲染
|
|
|
//public final static String MODEL_CREAT_THUM = "topic.modelCreatThum";
|
|
|
|
|
|
//上传模型
|
|
|
- public final static String MODEL = "topic.model."+active;
|
|
|
+ public final static String MODEL = "topic.model.uat";
|
|
|
//上传模型处理业务
|
|
|
- public final static String MODEL_BIZ = "topic.modelBiz."+active;
|
|
|
+ public final static String MODEL_BIZ = "topic.modelBiz.uat";
|
|
|
// 线下版本使用队列
|
|
|
- public final static String MODEL_BIZ_3D = "topic.3dModelBiz."+active;
|
|
|
+ public final static String MODEL_BIZ_3D = "topic.3dModelBiz.uat";
|
|
|
//"更新模型库,syncmodel
|
|
|
- public final static String SYNCMODEL = "topic.syncmodel."+active;
|
|
|
+ public final static String SYNCMODEL = "topic.syncmodel.uat";
|
|
|
|
|
|
//上传后提交模型
|
|
|
- public final static String ADDMODEL = "topic.addModel."+active;
|
|
|
+ public final static String ADDMODEL = "topic.addModel.uat";
|
|
|
//上传后提交模型3D端
|
|
|
- public final static String ADDMODELTO3D = "topic.addmodelto3d."+active;
|
|
|
+ public final static String ADDMODELTO3D = "topic.addmodelto3d.uat";
|
|
|
//处理
|
|
|
- public final static String MVIEW = "delay.mview."+active;
|
|
|
+ public final static String MVIEW = "delay.mview.uat";
|
|
|
|
|
|
/**
|
|
|
* 普通交换机
|
|
|
*/
|
|
|
- public final static String TOPICE = "topicExchange."+active;
|
|
|
+ public final static String TOPICE = "topicExchange.uat";
|
|
|
/**
|
|
|
* 延迟消息交换机
|
|
|
*/
|
|
|
- public final static String DELAY_EXCHANGE = "delay.exchange."+active;
|
|
|
+ public final static String DELAY_EXCHANGE = "delay.exchange.uat";
|
|
|
|
|
|
@Bean
|
|
|
public CustomExchange delayMessageExchange() {
|