#1229 Add test case

This commit is contained in:
nkorange 2019-06-28 17:06:06 +08:00
parent 88e11393a6
commit 86f0f3c6d7

View File

@ -19,6 +19,7 @@ import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingFactory;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.PreservedMetadataKeys;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.naming.NamingApp;
import org.junit.Assert;
@ -210,4 +211,36 @@ public class RegisterInstance_ITCase {
Assert.assertEquals("1.0", instances.get(0).getMetadata().get("version"));
Assert.assertEquals("prod", instances.get(0).getMetadata().get("env"));
}
@Test
public void regServiceWithTTL() throws Exception {
String serviceName = randomDomainName();
System.out.println(serviceName);
Instance instance = new Instance();
instance.setIp("1.1.1.2");
instance.setPort(9999);
Map<String, String> metadata = new HashMap<String, String>();
metadata.put(PreservedMetadataKeys.HEART_BEAT_INTERVAL, "3");
metadata.put(PreservedMetadataKeys.HEART_BEAT_TIMEOUT, "6");
metadata.put(PreservedMetadataKeys.IP_DELETE_TIMEOUT, "9");
instance.setMetadata(metadata);
naming.registerInstance(serviceName, instance);
TimeUnit.SECONDS.sleep(3);
List<Instance> instances = naming.getAllInstances(serviceName);
Assert.assertEquals(1, instances.size());
naming.deregisterInstance(serviceName, instance);
TimeUnit.SECONDS.sleep(12);
instances = naming.getAllInstances(serviceName);
Assert.assertEquals(0, instances.size());
}
}