From 00f5e1afea86cc5e5b438cf810463ec35b47af75 Mon Sep 17 00:00:00 2001 From: akiyamamioty <672795574@qq.com> Date: Wed, 16 Oct 2019 16:49:41 +0800 Subject: [PATCH] add validation on nameServer --- .../properties/RocketMQBinderConfigurationProperties.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/properties/RocketMQBinderConfigurationProperties.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/properties/RocketMQBinderConfigurationProperties.java index f903bcc08..6bfc63652 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/properties/RocketMQBinderConfigurationProperties.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/properties/RocketMQBinderConfigurationProperties.java @@ -16,21 +16,27 @@ package com.alibaba.cloud.stream.binder.rocketmq.properties; +import javax.validation.constraints.Pattern; + import com.alibaba.cloud.stream.binder.rocketmq.RocketMQBinderConstants; import org.apache.rocketmq.common.MixAll; import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.validation.annotation.Validated; /** * @author Timur Valiev * @author Jim */ @ConfigurationProperties(prefix = "spring.cloud.stream.rocketmq.binder") +@Validated public class RocketMQBinderConfigurationProperties { /** * The name server for rocketMQ, formats: `host:port;host:port`. */ + @Pattern(regexp = "^[\\d.:;]+$", + message = "nameServer needs to match expression \"host:port;host:port\"") private String nameServer = RocketMQBinderConstants.DEFAULT_NAME_SERVER; /**