本文共 1250 字，大约阅读时间需要 4 分钟。
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import java.util.Map;
import java.util.Optional;
@Data
@Component
@ConfigurationProperties("tieasy.mqs")
public class MqsProperties {
public static final String INSTANCE_INTERNAL = "internal";
public static final String INSTANCE_EXTERNAL = "external";
private Map instances;
private TopicProperties topics;
public RocketMQProperties getInstanceByName(String instanceName){
return Optional.ofNullable(instances)
.map(m -> m.get(instanceName))
.orElse(null);
}
@Data
public static class TopicProperties {
private String crane;
private String lift;
private WuxiTopics wuxi;
private XuzhouTopics xuzhou;
private String bazhou;
}
@Data
public static class WuxiTopics {
private String deviceAdd;
private String deviceEdit;
private String deviceDelete;
}
@Data
public static class XuzhouTopics {
private String deviceStatus;
private String deviceData;
private String deviceAdd;
private String deviceDelete;
}
@Data
public static class RocketMQProperties {
private String appId;
private String appSecret;
private String namesrcAddr;
private Integer consumeThreadMax = 32;
private Integer consumeThreadMin = 8;
}
}
转载地址：https://blog.csdn.net/weixin_32946543/article/details/115516893 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！
发表评论
最新留言
关于作者
