Skip to content

Commit e368bd0

Browse files
committed
feat:add config file changed queue operation logs. (#670)
Signed-off-by: Haotian Zhang <[email protected]>
1 parent 185bee5 commit e368bd0

File tree

1 file changed

+2
-0
lines changed
  • polaris-plugins/polaris-plugins-configuration-connector/consul-configuration-connector/src/main/java/com/tencent/polaris/plugins/configuration/connector/consul

1 file changed

+2
-0
lines changed

polaris-plugins/polaris-plugins-configuration-connector/consul-configuration-connector/src/main/java/com/tencent/polaris/plugins/configuration/connector/consul/ConsulConfigFileConnector.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,7 @@ public ConfigFileResponse getConfigFile(ConfigFile configFile) {
158158
ConfigFileResponse configFileResponse = getKVValues(configFile, keyPrefix);
159159
if (configFileResponse != null && configFileResponse.getCode() == CodeProto.Code.ExecuteSuccess.getNumber()) {
160160
blockingQueue.offer(new RefreshEventData(keyPrefix, configFile, configFileResponse));
161+
LOGGER.info("Offer consul config '{}' to config file changed queue.", keyPrefix);
161162
} else {
162163
if (configFileResponse != null) {
163164
LOGGER.debug("Watch consul config '{}' with {}.", keyPrefix, configFileResponse.getMessage());
@@ -304,6 +305,7 @@ public ConfigFileResponse watchConfigFiles(List<ConfigFile> configFiles) {
304305
try {
305306
RefreshEventData refreshEventData = blockingQueue.poll(30, TimeUnit.SECONDS);
306307
if (refreshEventData != null) {
308+
LOGGER.info("Poll consul config '{}' from config file changed queue.", refreshEventData.getKeyPrefix());
307309
Optional<ConfigFile> optional = configFiles.stream()
308310
.filter(configFile -> StringUtils.equals(refreshEventData.getKeyPrefix(), ConsulConfigFileUtils.toConsulKVKeyPrefix(configFile)))
309311
.findFirst();

0 commit comments

Comments
 (0)