From 5230444d5f83e586ce759d15e02ee799cf6241e7 Mon Sep 17 00:00:00 2001 From: tswstarplanet Date: Sun, 21 Jun 2020 00:12:40 +0800 Subject: [PATCH] fix publish null value when use consul config center (#6351) * fix publish null value when use consul config center --- .../configcenter/consul/ConsulDynamicConfiguration.java | 2 +- .../configcenter/consul/ConsulDynamicConfigurationTest.java | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java b/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java index 282bdef679..e0e9a86dda 100644 --- a/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java +++ b/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java @@ -145,7 +145,7 @@ public class ConsulDynamicConfiguration implements DynamicConfiguration { // } // return true; String normalizedKey = convertKey(group, key); - return kvClient.putValue(normalizedKey + PATH_SEPARATOR + content); + return kvClient.putValue(normalizedKey, content); } @Override diff --git a/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java b/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java index 8ada5fbdc0..d924c834e4 100644 --- a/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java +++ b/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java @@ -102,6 +102,12 @@ public class ConsulDynamicConfigurationTest { System.out.println(kvClient.getValues("/dubbo/config/dubbo/foo")); } + @Test + public void testPublishConfig() { + configuration.publishConfig("foo", "value1"); + Assertions.assertEquals("value1", configuration.getString("/dubbo/config/dubbo/foo")); + } + @Test public void testGetConfigKeys() {