<artifactId>ems-driver-boco-parent</artifactId>
<version>1.1.0-SNAPSHOT</version>
</parent>
+
<modelVersion>4.0.0</modelVersion>
<artifactId>boco-driver</artifactId>
<version>1.1.0-SNAPSHOT</version>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.5</version>
</dependency>
+ <!-- https://mvnrepository.com/artifact/org.mockftpserver/MockFtpServer -->
+
+ <dependency>
+ <groupId>org.mockftpserver</groupId>
+ <artifactId>MockFtpServer</artifactId>
+ <version>2.4</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.mock-server</groupId>
+ <artifactId>mockserver-netty</artifactId>
+ <version>3.10.4</version>
+ </dependency>
+
</dependencies>
</project>
this.zipFilePath = zipFilePath;
this.compressPath = compressFile.getAbsolutePath();
- if (this.zipFilePath == null) {
+ /*if (this.zipFilePath == null) {
StringBuffer zipFilePathBuf = new StringBuffer(this.compressPath);
int bufLen = zipFilePathBuf.length();
if (zipFilePathBuf.charAt(bufLen - 1) == '/')
zipFilePathBuf.deleteCharAt(bufLen - 1);
this.zipFilePath = zipFilePathBuf.append(".zip").toString();
- }
+ }*/
relativeAddrIdx = this.compressPath.lastIndexOf(File.separator) + 1;
}
import org.junit.Before;
import org.junit.Test;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CollectMsg;
+import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannel;
public class CollectMsgReceiverThreadTest {
CollectMsgReceiverThread col = null;
-
+
@Before
- public void setUp() {
+ public void setUp() throws Exception {
col = new CollectMsgReceiverThread();
}
col.setThread_max_num(1);
}
+
+ @Test
+ public void dispose1() {
+ new Thread() {
+ public void run() {
+ try {
+ Thread.sleep(61000);
+ col.setRun(false);
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ }.start();
+ col.setRun(true);
+ col.dispose();
+ col.getTaskService().stopTask();
+ col.getThread_max_num();
+ col.setThread_max_num(1);
+
+ }
}
*/
package org.onap.vfc.nfvo.emsdriver.commons.ftp;
+import static org.junit.Assert.*;
+
+
+import org.junit.Before;
+import org.junit.Test;
+import org.mockftpserver.fake.FakeFtpServer;
+import org.mockftpserver.fake.UserAccount;
+import org.mockftpserver.fake.filesystem.DirectoryEntry;
+import org.mockftpserver.fake.filesystem.FileEntry;
+import org.mockftpserver.fake.filesystem.FileSystem;
+import org.mockftpserver.fake.filesystem.UnixFakeFileSystem;
+
public class FTPSrvTest {
+ private FTPSrv fTPSrv;
+
+ @Before
+ public void setUp() throws Exception {
+ FakeFtpServer fakeFtpServer = new FakeFtpServer();
+ fakeFtpServer.setServerControlPort(10089);
+ // 创建服务器 添加用户
+ fakeFtpServer.addUserAccount(new UserAccount("123", "123", "/"));
+ // 建立文件系统
+ FileSystem fileSystem = new UnixFakeFileSystem();
+ fileSystem.add(new DirectoryEntry("/"));
+ fileSystem.add(new FileEntry("/data", "/ftp/aaa"));
+ fileSystem.add(new FileEntry("/data/License.txt", "/ftp/aaa/License.txt"));
+ fakeFtpServer.setFileSystem(fileSystem);
+ fakeFtpServer.start();
+
+ fTPSrv = new FTPSrv();
+ }
+
+ @Test
+ public void testTrue() throws Exception {
+ fTPSrv.login("127.0.0.1", 10089, "123", "123", "utf-8", true, 30000);
+ String pwd = fTPSrv.pwd();
+ boolean isDir = fTPSrv.chdir("/ftp");
+ fTPSrv.downloadFile("/ftp/aaa/License.txt", "data/bbb.txt");
+ fTPSrv.list();
+ fTPSrv.logout();
+ assertNotNull(pwd);
+ assertTrue(!isDir);
+ }
+
+ @Test
+ public void testFalse() throws Exception {
+ fTPSrv.login("127.0.0.1", 10089, "123", "123", "utf-8", false, 30000);
+ String pwd = fTPSrv.pwd();
+ boolean isDir = fTPSrv.chdir("/ftp");
+ fTPSrv.downloadFile("/ftp/aaa/License.txt", "data/bbb.txt");
+ fTPSrv.list();
+ fTPSrv.logout();
+ assertNotNull(pwd);
+ assertTrue(!isDir);
+ }
+
}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.commons.model;
+
+import static org.junit.Assert.*;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class CrontabVoTest {
+
+ private CrontabVo crontabVo;
+
+ @Before
+ public void setUp() throws Exception {
+ crontabVo = new CrontabVo();
+ }
+
+ @Test
+ public void testToString() {
+ crontabVo.setCrontab("crontab");
+ crontabVo.setGranularity("crontab");
+ crontabVo.setIscollect(true);
+ crontabVo.setMatch("crontab");
+ crontabVo.setRead_timeout("10000");
+ crontabVo.setType("qw");
+ assertNotNull(crontabVo.toString());
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.commons.utils;
+
+import static org.junit.Assert.*;
+
+import java.text.ParseException;
+import java.util.Date;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class DateUtilTest {
+
+ private Date fireTime;
+
+ @Before
+ public void setUp() throws Exception {
+ fireTime = new Date();
+ }
+
+ @Test
+ public void testGetScanScope() {
+ long[] scanScope = DateUtil.getScanScope(fireTime, 3600);
+ long start = scanScope[0];
+ long end = scanScope[1];
+
+ long[] scanScope1 = DateUtil.getScanScope(fireTime, 3000);
+ long start1 = scanScope1[0];
+ long end1 = scanScope1[1];
+
+ long[] scanScope2 = DateUtil.getScanScope(fireTime, 24 * 60 * 60);
+ long start2 = scanScope2[0];
+ long end2 = scanScope2[1];
+
+ long[] scanScope3 = DateUtil.getScanScope(fireTime, 4200);
+ long start3 = scanScope3[0];
+ long end3 = scanScope3[1];
+
+ assertNotNull(start);
+ assertNotNull(end);
+ assertNotNull(start1);
+ assertNotNull(end1);
+ assertNotNull(start2);
+ assertNotNull(end2);
+ assertNotNull(start3);
+ assertNotNull(end3);
+ }
+
+ @Test
+ public void testTimeString() {
+ String timeString = DateUtil.TimeString(null);
+ String timeString1 = DateUtil.TimeString("20180206T");
+ String timeString2 = DateUtil.TimeString("20180206T+12");
+ assertNotNull(timeString);
+ assertNotNull(timeString1);
+ assertNotNull(timeString2);
+ }
+
+ @Test
+ public void testAddTime() throws Exception {
+ String addTime = DateUtil.addTime("2018-02-06 11:47:00","2");
+ System.out.println(addTime);
+ assertNotNull(addTime);
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.commons.utils;
+
+import static org.junit.Assert.*;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class DriverThreadTest {
+
+ private DriverThread driverThread;
+ private DriverThread driverThread1;
+ @Before
+ public void setUp() throws Exception {
+ driverThread = new DriverThread() {
+ @Override
+ public void dispose() {
+ setName("name");
+ getName();
+ isEnd();
+ setEnd(true);
+ interrupt();
+ stop();
+ }
+ };
+ driverThread1 = new DriverThread() {
+ @Override
+ public void dispose() {
+ //setName(null);
+ getName();
+ isRun();
+ isEnd();
+ setEnd(false);
+ //interrupt();
+ stop();
+ }
+ };
+ }
+
+ @Test
+ public void testDriverThread() {
+
+ Thread t = new Thread(driverThread);
+ t.start();
+ //fail("Not yet implemented");
+ }
+ /*@Test
+ public void testDriverThread1() {
+
+ Thread t = new Thread(driverThread1);
+ t.start();
+ //fail("Not yet implemented");
+ }*/
+
+}
@Test
public void testGetStackTrace() {
String str = StringUtil.getStackTrace(throwable);
-
+
assertNotNull(str);
}
@Test
public void testAddSlash() {
String str = StringUtil.addSlash("aa/bb");
+ String str1 = StringUtil.addSlash("aa/bb"+File.separator);
assertTrue(str.endsWith(File.separator));
+ assertTrue(str1.endsWith(File.separator));
}
@Test
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.commons.utils;
+
+import static org.junit.Assert.*;
+
+import java.util.Date;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class VarExprParserTest {
+
+ private Date date;
+ private long time;
+
+ @Before
+ public void setUp() throws Exception {
+ date = new Date();
+ time = date.getTime();
+ }
+
+ @Test
+ public void testReplaceVar() {
+ String str = VarExprParser.replaceVar("asd", time, time);
+ //String str1 = VarExprParser.replaceVar("${s_year}12+45-7h", time, time);
+ //String str2 = VarExprParser.replaceVar("${s_mon}12+45-7m,23453", time, time);
+ String str3 = VarExprParser.replaceVar("${s_day}", time, time);
+ String str4 = VarExprParser.replaceVar("${s_hour}", time, time);
+ String str5 = VarExprParser.replaceVar("${s_min}", time, time);
+ String str6 = VarExprParser.replaceVar("${e_year}", time, time);
+ String str7 = VarExprParser.replaceVar("${e_mon}", time, time);
+ String str8 = VarExprParser.replaceVar("${e_day}", time, time);
+ String str9 = VarExprParser.replaceVar("${e_hour}", time, time);
+ String str0 = VarExprParser.replaceVar("${e_min}", time, time);
+
+ assertNotNull(str);
+ //assertNotNull(str1);
+ //assertNotNull(str2);
+ assertNotNull(str3);
+ assertNotNull(str4);
+ assertNotNull(str5);
+ assertNotNull(str6);
+ assertNotNull(str7);
+ assertNotNull(str8);
+ assertNotNull(str9);
+ assertNotNull(str0);
+
+ }
+
+ @Test
+ public void testReplaceTimeVar() {
+ String start = VarExprParser.replaceTimeVar("${SCAN_START_TIME}", "start", "stop");
+ String stop = VarExprParser.replaceTimeVar("${SCAN_STOP_TIME}", "start", "stop");
+
+ assertNotNull(start);
+ assertNotNull(stop);
+
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.commons.utils;
+
+import static org.junit.Assert.*;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+
+import org.jdom.Document;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+public class XmlUtilTest {
+
+ private InputStream is;
+
+ @Before
+ public void setUp() throws Exception {
+ is = new FileInputStream("conf/spring.xml");
+ //is = new FileInputStream("/opt/gframe/jenkins/workspace/ems0206/logback.xml");
+
+ }
+
+ @Test
+ public void testGetDocument() throws Exception {
+ Document doc = XmlUtil.getDocument(is);
+ assertTrue(doc!=null);
+ }
+
+ @After
+ public void setDown() throws IOException {
+ is.close();
+ }
+
+}
public class ZipTest {
private String file = "./test.txt";
+ //private String file1 = "./";
private String tofile1 = "./test.zip";
private Zip zip = null;
+ //private Zip zip1 = null;
@Before
public void setUp() throws IOException {
new File(file).createNewFile();
zip = new Zip(file, tofile1);
+ //zip1 = new Zip(file1, null);
}
-
+
@Test
public void compress() throws IOException {
+ //zip1.compress();
zip.compress();
-
+
assertTrue(tofile1.endsWith(".zip"));
}
System.out.println(list);
assertTrue(list.size() > 0);
}
+
+ @Test
+ public void testDispose() {
+ configurationManager.dispose();
+ }
}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.northbound.client;
+
+import static org.junit.Assert.*;
+
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.junit.Before;
+import org.junit.Test;
+
+public class HttpClientFactoryTest {
+
+ @Before
+ public void setUp() throws Exception {
+ }
+
+ @Test
+ public void test() throws Exception {
+ CloseableHttpClient client = HttpClientFactory.getSSLClientFactory();
+ assertTrue(client!=null);
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.northbound.client;
+
+import static org.junit.Assert.*;
+import static org.hamcrest.CoreMatchers.equalTo;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.mockserver.client.server.MockServerClient;
+import org.mockserver.junit.MockServerRule;
+import org.mockserver.model.Header;
+
+import static org.mockserver.model.HttpRequest.request;
+import static org.mockserver.model.HttpResponse.response;
+
+import javax.ws.rs.core.MediaType;
+
+import org.apache.http.HttpHeaders;
+
+public class HttpClientUtilTest {
+
+ @Rule
+ public MockServerRule server = new MockServerRule(this, 10086);
+
+ @Before
+ public void setUp() throws Exception {
+
+ }
+
+ @Test
+ public void testDoGet() {
+ MockServerClient mockClient = new MockServerClient("localhost", 10086);
+ String expected = "{ message: 'incorrect username and password combination' }";
+ mockClient.when(request().withPath("/hello/John").withMethod("GET")
+ // .withHeader(new Header(HttpHeaders.ACCEPT, MediaType.TEXT_PLAIN))
+ // .withQueryStringParameter(new Parameter("my-token", "12345"))
+ ).respond(response().withStatusCode(200).withBody(expected));
+
+ String responseText = HttpClientUtil.doGet("http://localhost:10086/hello/John", "utf-8");
+ assertThat(responseText, equalTo(expected));
+
+ }
+
+ @Test
+ public void testDoPost() {
+ MockServerClient mockClient = new MockServerClient("localhost", 10086);
+ String expected = "You have logged in successfully.";
+ mockClient
+ .when(request().withPath("/hello/John").withMethod("POST")
+ //.withHeader(new Header(HttpHeaders.ACCEPT, MediaType.TEXT_PLAIN))
+ // .withQueryStringParameter(new Parameter("my-token", "12345"))
+ .withBody("username=foo&password=123456"))
+ .respond(response().withStatusCode(200).withBody(expected));
+
+ String responseText = HttpClientUtil.doPost("http://localhost:10086/hello/John", "username=foo&password=123456", "utf-8");
+ //"{\"username\":\"foo\",\"password\":\"123456\"}"
+ // 验证输出是否是正确
+ assertThat(responseText, equalTo(expected));
+
+ }
+
+ @Test
+ public void testDoDelete() {
+ MockServerClient mockClient = new MockServerClient("localhost", 10086);
+ String expected = "{ message: 'incorrect username and password combination' }";
+ mockClient.when(request().withPath("/hello/John").withMethod("DELETE")
+ // .withHeader(new Header(HttpHeaders.ACCEPT, MediaType.TEXT_PLAIN))
+ // .withQueryStringParameter(new Parameter("my-token", "12345"))
+ ).respond(response().withStatusCode(200).withBody(expected));
+
+ String responseText = HttpClientUtil.doDelete("http://localhost:10086/hello/John", "utf-8");
+ assertThat(responseText, equalTo(expected));
+
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.northbound.client;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class NorthMessageMgrTest {
+
+ /*private NorthMessageMgr northMessageMgr;
+ private ConfigurationInterface configurationInterface;*/
+
+ @Before
+ public void setUp() throws Exception {
+ /*configurationInterface = new ConfigurationInterface() {
+
+ public Properties getProperties() {
+ Properties pps = new Properties();
+ try {
+ pps.load(new FileInputStream("conf/ftpconfig.properties"));
+ } catch (Exception e) {
+ }
+ return pps;
+ }
+
+ public CollectVo getCollectVoByEmsNameAndType(String emsName, String type) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ public List<EMSInfo> getAllEMSInfo() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+ };
+ northMessageMgr = new NorthMessageMgr();
+ northMessageMgr.setConfigurationInterface(configurationInterface);
+ northMessageMgr.dispose();
+ */
+ }
+
+ @Test
+ public void test() {
+ /*Thread t = new Thread(northMessageMgr);
+ t.start();*/
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.taskscheduler;
+
+import static org.junit.Assert.*;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationImp;
+import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationInterface;
+
+public class CollectManagerTest {
+
+ private CollectManager collectManager;
+ private ConfigurationInterface configurationInterface;
+
+
+ @Before
+ public void setUp() throws Exception {
+ configurationInterface = new ConfigurationImp();
+
+ collectManager = new CollectManager();
+ collectManager.setConfigurationInterface(configurationInterface);
+ collectManager.dispose();
+ }
+
+ @Test
+ public void test() {
+ Thread t = new Thread(collectManager);
+ t.start();
+ }
+
+}
--- /dev/null
+/*
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.vfc.nfvo.emsdriver.taskscheduler;
+
+import static org.junit.Assert.*;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
+
+public class QuartzManagerTest {
+
+ private CollectVo collectVo;
+ @Before
+ public void setUp() throws Exception {
+ collectVo = new CollectVo();
+ collectVo.setIP("127.0.0.1");
+ }
+
+ @Test
+ public void test() {
+ QuartzManager.addJob("QuartzManager", "org.onap.vfc.nfvo.emsdriver.taskscheduler", "11", collectVo);
+ QuartzManager.modifyJobTime("QuartzManager", "org.onap.vfc.nfvo.emsdriver.taskscheduler", collectVo);
+ QuartzManager.startJobs();
+ QuartzManager.shutdownJobs();
+ QuartzManager.removeJob("QuartzManager");
+
+ }
+
+}
Code Review / vfc / nfvo / driver / ems.git / commitdiff