zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(remove ConfigLongPollTest):

Browse Source
This commit is contained in:
chuntaojun 2019-06-07 16:58:29 +08:00
parent be213f5601
commit 92ff0a0873
1 changed files with 81 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

162
client/src/test/java/com/alibaba/nacos/client/ConfigLongPollTest.java
View File

@ -1,81 +1,81 @@
/* ///*
* Copyright 1999-2018 Alibaba Group Holding Ltd. // * Copyright 1999-2018 Alibaba Group Holding Ltd.
* // *
* Licensed under the Apache License, Version 2.0 (the "License"); // * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. // * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at // * You may obtain a copy of the License at
* // *
* http://www.apache.org/licenses/LICENSE-2.0 // * http://www.apache.org/licenses/LICENSE-2.0
* // *
* Unless required by applicable law or agreed to in writing, software // * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, // * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and // * See the License for the specific language governing permissions and
* limitations under the License. // * limitations under the License.
*/ // */
//
package com.alibaba.nacos.client; //package com.alibaba.nacos.client;
//
import com.alibaba.nacos.api.NacosFactory; //import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst; //import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigService; //import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener; //import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException; //import com.alibaba.nacos.api.exception.NacosException;
import org.junit.Before; //import org.junit.Before;
import org.junit.Test; //import org.junit.Test;
//
import java.util.Properties; //import java.util.Properties;
import java.util.concurrent.Executor; //import java.util.concurrent.Executor;
//
/** ///**
* @author liaochuntao // * @author liaochuntao
* @date 2019-06-07 16:37 // * @date 2019-06-07 16:37
**/ // **/
public class ConfigLongPollTest { //public class ConfigLongPollTest {
//
private ConfigService configService; // private ConfigService configService;
//
@Before // @Before
public void init() throws NacosException { // public void init() throws NacosException {
Properties properties = new Properties(); // Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, "127.0.0.1:8848"); // properties.put(PropertyKeyConst.SERVER_ADDR, "127.0.0.1:8848");
properties.put(PropertyKeyConst.CONFIG_RETRY_TIME, 2000); // properties.put(PropertyKeyConst.CONFIG_RETRY_TIME, 2000);
properties.put(PropertyKeyConst.CONFIG_RETRY_TIME, 5000); // properties.put(PropertyKeyConst.CONFIG_RETRY_TIME, 5000);
configService = NacosFactory.createConfigService(properties); // configService = NacosFactory.createConfigService(properties);
} // }
//
@Test // @Test
public void test() throws InterruptedException, NacosException { // public void test() throws InterruptedException, NacosException {
//
synchronized (this) { // synchronized (this) {
//
configService.addListener("test", "DEFAULT_GROUP", new Listener() { // configService.addListener("test", "DEFAULT_GROUP", new Listener() {
@Override // @Override
public Executor getExecutor() { // public Executor getExecutor() {
return null; // return null;
} // }
//
@Override // @Override
public void receiveConfigInfo(String configInfo) { // public void receiveConfigInfo(String configInfo) {
System.out.println(configInfo); // System.out.println(configInfo);
} // }
}); // });
//
configService.addListener("test-1", "DEFAULT_GROUP", new Listener() { // configService.addListener("test-1", "DEFAULT_GROUP", new Listener() {
@Override // @Override
public Executor getExecutor() { // public Executor getExecutor() {
return null; // return null;
} // }
//
@Override // @Override
public void receiveConfigInfo(String configInfo) { // public void receiveConfigInfo(String configInfo) {
System.out.println(configInfo); // System.out.println(configInfo);
} // }
}); // });
//
wait(); // wait();
} // }
//
} // }
//
} //}