提交 0f6a68ee 编写于 作者: zhouweidong's avatar zhouweidong

消息配置

上级 67e5fa82
......@@ -45,7 +45,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
@Slf4j
@Configuration
@ConditionalOnExpression("${r'${rocketmq.consumer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
@ConditionalOnExpression("'${r'${rocketmq.consumer.isOnOff:'+mqServer+"}'.equals('on')"}")
public class RocketMQConsumer {
@Value("${r'${rocketmq.consumer.groupName:default}'}")
......
......@@ -50,7 +50,7 @@ import java.util.List;
*/
@Slf4j
@Component
@ConditionalOnExpression("${r'${rocketmq.consumer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
@ConditionalOnExpression("'${r'${rocketmq.consumer.isOnOff:'+mqServer+"}'.equals('on')"}")
public class RocketMQListenerProcessor implements MessageListenerOrderly {
<#list sys.getAllPSDataEntities() as dataEntity>
......
......@@ -45,7 +45,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
@Slf4j
@Configuration
@ConditionalOnExpression("${r'${rocketmq.producer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
@ConditionalOnExpression("'${r'${rocketmq.producer.isOnOff:'+mqServer+"}'.equals('on')"}")
public class RocketMQProducer {
@Value("${r'${rocketmq.producer.groupName:default}'}")
......
......@@ -61,7 +61,7 @@ import java.util.List;
@Slf4j
@Aspect
@Component
@ConditionalOnExpression("${r'${rocketmq.producer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
@ConditionalOnExpression("'${r'${rocketmq.producer.isOnOff:'+mqServer+"}'.equals('on')"}")
public class RocketMQAspect
{
private final ExpressionParser parser = new SpelExpressionParser();
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册