public class EMSDriverApp {
private static Log log = LogFactory.getLog(DriverThread.class);
- public static ApplicationContext context = null;
+ private static ApplicationContext context = null;
static {
try {
/** spring bean applicationContext **/
if (thread == null) {
log.error(threadName + "Thread start error,system exit");
System.exit(1);
+ }else{
+ thread.setName(threadName);
+ thread.start();
}
- thread.setName(threadName);
- thread.start();
+
}
try {
import io.dropwizard.Application;
import io.dropwizard.assets.AssetsBundle;
import io.dropwizard.jetty.HttpConnectorFactory;
-import io.dropwizard.server.DefaultServerFactory;
import io.dropwizard.server.SimpleServerFactory;
import io.dropwizard.setup.Bootstrap;
import io.dropwizard.setup.Environment;
public class EmsDriverApplication extends Application<EmsDriverConfiguration> {
protected static Log log = LogFactory.getLog(EmsDriverApplication.class);
- public static ApplicationContext context = null;
+ private ApplicationContext context = null;
public static void main(String[] args) throws Exception {
new EmsDriverApplication().run(args);
MsbConfiguration.setMsbAddress(configuration.getMsbAddress());
//MSB register
String registerFlag = configuration.getAutoServiceRegister();
- if(registerFlag.equalsIgnoreCase("false")){
+ if("false".equalsIgnoreCase(registerFlag)){
this.msbRegisteEmsDriverService(configuration);
}
//Start workThread
if (thread == null) {
log.error(threadName + "Thread start error,system exit");
System.exit(1);
+ }else{
+ thread.setName(threadName);
+ thread.start();
}
- thread.setName(threadName);
- thread.start();
+
}
}
// init swagger
try {
ip = InetAddress.getLocalHost().getHostAddress();
} catch (UnknownHostException e) {
- log.error("Unable to get host ip: " + e.getMessage());
+ log.error("Unable to get host ip: ",e);
}
if(ip.equals("")){
ip = connector.getBindHost();
this.thread_max_num = thread_max_num;
}
+
+
+ /**
+ * @return the taskService
+ */
+ public TaskThreadService getTaskService() {
+ return taskService;
+ }
+
+
+
}
public Log log = LogFactory.getLog(TaskThread.class);
private MessageChannel cmResultChannel;
- private MessageChannel pmResultChannel;
+ public MessageChannel pmResultChannel;
private CollectMsg data;
}
}
- private void parseFtpAndSendMessage(String fileName, CollectVo collectVo) {
+ public void parseFtpAndSendMessage(String fileName, CollectVo collectVo) {
//
List<File> filelist = decompressed(fileName);
String valueLine = "";
List<String> valuelist = new ArrayList<String>();
- while (br.readLine() != null) {
+ while ((valueLine = br.readLine()) != null) {
if (valueLine.trim().equals("")) {
continue;
}
}
}
- private String createMessage(String zipName,String user,String pwd,String ip, String port,int countNum, String nename) {
+ public String createMessage(String zipName,String user,String pwd,String ip, String port,int countNum, String nename) {
StringBuffer strBuffer = new StringBuffer();
strBuffer
log.error(StringUtil.getStackTrace(e));
}
} catch (Exception e) {
+ e.printStackTrace();
reinit();
}
}
}
}
}
+
+ /**
+ * @param isStop the isStop to set
+ */
+ public void setStop(boolean isStop) {
+ this.isStop = isStop;
+ }
+
+ /**
+ * @return the heartBeat
+ */
+ public HeartBeat getHeartBeat() {
+ return heartBeat;
+ }
+
+
+
}
*/
package org.onap.vfc.nfvo.emsdriver.commons.ftp;
-import java.io.IOException;
-
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
protected FTPFile ftpFile = null;
protected String currDir = null;
- public AFtpRemoteFile(FTPFile rfile, FTPClient ftpClient, String currDir)
- throws IOException {
+ public AFtpRemoteFile(FTPFile rfile, FTPClient ftpClient, String currDir){
this.ftpClient = ftpClient;
this.ftpFile = rfile;
this.currDir = currDir;
+++ /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.ftp;
-
-import org.apache.commons.net.ftp.Configurable;
-import org.apache.commons.net.ftp.FTPClientConfig;
-import org.apache.commons.net.ftp.FTPFileEntryParser;
-import org.apache.commons.net.ftp.parser.CompositeFileEntryParser;
-import org.apache.commons.net.ftp.parser.DefaultFTPFileEntryParserFactory;
-import org.apache.commons.net.ftp.parser.MVSFTPEntryParser;
-import org.apache.commons.net.ftp.parser.NTFTPEntryParser;
-import org.apache.commons.net.ftp.parser.OS2FTPEntryParser;
-import org.apache.commons.net.ftp.parser.OS400FTPEntryParser;
-import org.apache.commons.net.ftp.parser.ParserInitializationException;
-import org.apache.commons.net.ftp.parser.UnixFTPEntryParser;
-import org.apache.commons.net.ftp.parser.VMSVersioningFTPEntryParser;
- /**
- * This is the default implementation of the
- * FTPFileEntryParserFactory interface. This is the
- * implementation that will be used by
- * org.apache.commons.net.ftp.FTPClient.listFiles()
- * if no other implementation has been specified.
- *
- * @see org.apache.commons.net.ftp.FTPClient#listFiles
- * @see org.apache.commons.net.ftp.FTPClient#setParserFactory
- */
-public class ExtendsDefaultFTPFileEntryParserFactory extends
- DefaultFTPFileEntryParserFactory {
-
- private FTPClientConfig config = null;
-
- /**
- * This default implementation of the FTPFileEntryParserFactory
- * interface works according to the following logic:
- * First it attempts to interpret the supplied key as a fully
- * qualified classname of a class implementing the
- * FTPFileEntryParser interface. If that succeeds, a parser
- * object of this class is instantiated and is returned;
- * otherwise it attempts to interpret the key as an identirier
- * commonly used by the FTP SYST command to identify systems.
- * <p/>
- * If <code>key</code> is not recognized as a fully qualified
- * classname known to the system, this method will then attempt
- * to see whether it <b>contains</b> a string identifying one of
- * the known parsers. This comparison is <b>case-insensitive</b>.
- * The intent here is where possible, to select as keys strings
- * which are returned by the SYST command on the systems which
- * the corresponding parser successfully parses. This enables
- * this factory to be used in the auto-detection system.
- * <p/>
- *
- * @param key should be a fully qualified classname corresponding to
- * a class implementing the FTPFileEntryParser interface<br/>
- * OR<br/>
- * a string containing (case-insensitively) one of the
- * following keywords:
- * <ul>
- * <li>{@link FTPClientConfig#SYST_UNIX UNIX}</li>
- * <li>{@link FTPClientConfig#SYST_NT WINDOWS}</li>
- * <li>{@link FTPClientConfig#SYST_OS2 OS/2}</li>
- * <li>{@link FTPClientConfig#SYST_OS400 OS/400}</li>
- * <li>{@link FTPClientConfig#SYST_VMS VMS}</li>
- * <li>{@link FTPClientConfig#SYST_MVS MVS}</li>
- * </ul>
- * @return the FTPFileEntryParser corresponding to the supplied key.
- * @throws ParserInitializationException thrown if for any reason the factory cannot resolve
- * the supplied key into an FTPFileEntryParser.
- * @see FTPFileEntryParser
- */
- public FTPFileEntryParser createFileEntryParser(String key)
- {
- @SuppressWarnings("rawtypes")
- Class parserClass = null;
- FTPFileEntryParser parser = null;
- try
- {
- parserClass = Class.forName(key);
- parser = (FTPFileEntryParser) parserClass.newInstance();
- }
- catch (ClassNotFoundException e)
- {
- String ukey = null;
- if (null != key)
- {
- ukey = key.toUpperCase();
- }
- if (ukey.indexOf(FTPClientConfig.SYST_UNIX) >= 0)
- {
- parser = createUnixFTPEntryParser();
- }
- else if (ukey.indexOf(FTPClientConfig.SYST_VMS) >= 0)
- {
- parser = createVMSVersioningFTPEntryParser();
- }
- else if (ukey.indexOf(FTPClientConfig.SYST_NT) >= 0 || ukey.indexOf("DOPRA") >= 0 || ukey.indexOf("MSDOS") >= 0)
- {
- parser = createNTFTPEntryParser();
- }
- else if (ukey.indexOf(FTPClientConfig.SYST_OS2) >= 0)
- {
- parser = createOS2FTPEntryParser();
- }
- else if (ukey.indexOf(FTPClientConfig.SYST_OS400) >= 0)
- {
- parser = createOS400FTPEntryParser();
- }
- else if (ukey.indexOf(FTPClientConfig.SYST_MVS) >= 0)
- {
- parser = createMVSEntryParser();
- }
- else
- {
- throw new ParserInitializationException("Unknown parser type: " + key);
- }
- }
- catch (ClassCastException e)
- {
- throw new ParserInitializationException(parserClass.getName()
- + " does not implement the interface "
- + "org.apache.commons.net.ftp.FTPFileEntryParser.", e);
- }
- catch (Throwable e)
- {
- throw new ParserInitializationException("Error initializing parser", e);
- }
-
- if (parser instanceof Configurable) {
- ((Configurable)parser).configure(this.config);
- }
- return parser;
- }
-
- /**
- * <p>Implementation extracts a key from the supplied
- * {@link FTPClientConfig FTPClientConfig}
- * parameter and creates an object implementing the
- * interface FTPFileEntryParser and uses the supplied configuration
- * to configure it.
- * </p><p>
- * Note that this method will generally not be called in scenarios
- * that call for autodetection of parser type but rather, for situations
- * where the user knows that the server uses a non-default configuration
- * and knows what that configuration is.
- * </p>
- * @param config A {@link FTPClientConfig FTPClientConfig}
- * used to configure the parser created
- *
- * @return the @link FTPFileEntryParser FTPFileEntryParser} so created.
- * @exception ParserInitializationException
- * Thrown on any exception in instantiation
- * @since 1.4
- */
- public FTPFileEntryParser createFileEntryParser(FTPClientConfig config)
- throws ParserInitializationException
- {
- this.config = config;
- String key = config.getServerSystemKey();
- return createFileEntryParser(key);
- }
-
-
- public FTPFileEntryParser createUnixFTPEntryParser()
- {
- return (FTPFileEntryParser) new UnixFTPEntryParser();
- }
-
- public FTPFileEntryParser createVMSVersioningFTPEntryParser()
- {
- return (FTPFileEntryParser) new VMSVersioningFTPEntryParser();
- }
-
- public FTPFileEntryParser createNTFTPEntryParser()
- {
- if (config != null && FTPClientConfig.SYST_NT.equals(
- config.getServerSystemKey()))
- {
- return new NTFTPEntryParser();
- } else {
- return new CompositeFileEntryParser(new FTPFileEntryParser[]
- {
- new NTFTPEntryParser(),
- new UnixFTPEntryParser()
- });
- }
- }
-
- public FTPFileEntryParser createOS2FTPEntryParser()
- {
- return (FTPFileEntryParser) new OS2FTPEntryParser();
- }
-
- public FTPFileEntryParser createOS400FTPEntryParser()
- {
- if (config != null &&
- FTPClientConfig.SYST_OS400.equals(config.getServerSystemKey()))
- {
- return new OS400FTPEntryParser();
- } else {
- return new CompositeFileEntryParser(new FTPFileEntryParser[]
- {
- new OS400FTPEntryParser(),
- new UnixFTPEntryParser()
- });
- }
- }
-
- public FTPFileEntryParser createMVSEntryParser()
- {
- return new MVSFTPEntryParser();
- }
-}
package org.onap.vfc.nfvo.emsdriver.commons.ftp;
import java.io.BufferedOutputStream;
-import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.TimeZone;
+++ /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.ftp;
-
-public class SFTPSrv implements FTPInterface{
-
- public boolean chdir(String dir) {
- // TODO Auto-generated method stub
- return false;
- }
-
- public boolean downloadFile(String remoteFile, String localFile) {
- // TODO Auto-generated method stub
- return false;
- }
-
- public RemoteFile[] list() {
- // TODO Auto-generated method stub
- return null;
- }
-
- public RemoteFile[] list(String dir) {
- // TODO Auto-generated method stub
- return null;
- }
-
- public void login(String host, int port, String user, String pwd,
- String encode, boolean isPassiveMode, int timeout) throws Exception {
- // TODO Auto-generated method stub
-
- }
-
- public void logout() {
- // TODO Auto-generated method stub
-
- }
-
- public boolean store(String localFile, String remoteFile) {
- // TODO Auto-generated method stub
- return false;
- }
-
-
-}
-
Document doc = builder.build(is);
return doc;
}
- public static Document getDocument(Reader reader) throws XMLStreamException, JDOMException, IOException{
- SAXBuilder builder = new SAXBuilder();
- Document doc = builder.build(reader);
- return doc;
- }
}
List<String> ipList = new ArrayList<String>();
String url = MsbConfiguration.getMsbAddress()+Constant.MSBAPIROOTDOMAIN+"/"+serviceName+"/version/"+version;
String response = HttpClientUtil.doGet(url, Constant.ENCODING_UTF8);
- if(!response.equals("")){
+ if(response !=null && !"".equals(response)){
MsbRegisterVo msbRegisterVo = JSON.parseObject(response,MsbRegisterVo.class);
List<ServiceNodeVo> nodeList = msbRegisterVo.getNodes();
--- /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.collector;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CollectMsg;
+
+public class CollectMsgReceiverThreadTest {
+
+ CollectMsgReceiverThread col = null;
+ @Before
+ public void setUp() {
+ col = new CollectMsgReceiverThread();
+ }
+
+
+ @Test
+ public void dispose() {
+ new Thread(){
+ public void run() {
+ try {
+ Thread.sleep(10);
+ 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);
+
+ }
+}
@Test
public void add() {
taskThreadService.add(collectMsg);
+ taskThreadService.size();
+ new Thread(){
+ public void run() {
+ try {
+ Thread.sleep(10);
+ taskThreadService.stopTask();
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ }.start();
+ taskThreadService.run();
+
}
@Test
public void receive() {
taskThreadService.add(collectMsg);
CollectMsg collectMsg = taskThreadService.receive();
+
assertNotNull(collectMsg);
}
+
+
}
import org.junit.Before;
import org.junit.Test;
import org.onap.vfc.nfvo.emsdriver.collector.TaskThread;
+import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
import org.onap.vfc.nfvo.emsdriver.commons.utils.Gzip;
+import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannelFactory;
public class TaskThreadTest {
private String csvPath = System.getProperty("user.dir")+"/data/" +"PM-ENB-EUTRANCELLNB-test.csv";
@Before
public void setUp() throws IOException {
taskThread = new TaskThread();
+ taskThread.pmResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_CHANNEL_KEY);
Gzip gzip = new Gzip();
gzip.compress(csvPath, gzPath);
}
}
}
+ @Test
+ public void parseFtpAndSendMessage(){
+ CollectVo collectVo = new CollectVo();
+ collectVo.setType("ems-p");
+ taskThread.parseFtpAndSendMessage(gzPath,collectVo);
+ }
+
+ @Test
+ public void createMessage(){
+ CollectVo collectVo = new CollectVo();
+ collectVo.setType("ems-p");
+ taskThread.createMessage("zipName", "user", "pwd", "ip", "port", 122, "nename");
+ }
+
+
+
+
+
@After
public void setDown() throws IOException {
new File(gzPath).delete();
--- /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.collector.alarm;
+
+import java.io.BufferedOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.net.SocketTimeoutException;
+
+public class AlarmSocketServer {
+
+ boolean stop = false;
+ InputStreamReader isr = null;
+ BufferedOutputStream dos = null;
+ Socket socket = null;
+ ServerSocket server = null;
+ public void socketServer(){
+
+ try {
+ server = new ServerSocket(12345);
+ socket = server.accept();
+
+ socket.setSoTimeout(3*1000);
+ socket.setTcpNoDelay(true);
+ socket.setKeepAlive(true);
+ InputStream in = socket.getInputStream();
+ isr = new InputStreamReader(in);
+ dos = new BufferedOutputStream(socket.getOutputStream());
+ while(!stop){
+ int len = 0;
+ char b[] = new char[1024 * 8];
+ try{
+ len = isr.read(b, 0, b.length);
+ }catch(SocketTimeoutException e){
+ e.printStackTrace();
+ break;
+ }
+ if (len > 0) {
+ String restlu = new String(b, 0, len);
+ if(restlu.contains("reqLoginAlarm")){
+ Msg msg = new Msg("ackLoginAlarm;result=succ;resDesc= ",MsgType.ackLoginAlarm);
+
+ MessageUtil.writeMsg(msg,dos);
+ }
+ if(restlu.contains("reqHeartBeat")){
+ Msg msg = new Msg("ackHeartBeat;result=succ;resDesc= ",MsgType.ackHeartBeat);
+
+ MessageUtil.writeMsg(msg,dos);
+ }
+ Msg msg = new Msg("realTimeAlarm;result=succ;resDesc= ",MsgType.realTimeAlarm);
+
+ MessageUtil.writeMsg(msg,dos);
+
+
+
+ }else{
+ System.out.println("len:" +len);
+ Thread.sleep(10);
+ }
+
+ }
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ public void stop(){
+ try {
+ stop = true;
+ if(isr != null){
+ isr.close();
+ }
+ if(dos != null){
+ dos.close();
+ }
+ if(socket != null){
+ socket.close();
+ }
+ if(server != null){
+ server.close();
+ }
+
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+}
import org.junit.Before;
import org.junit.Test;
import org.onap.vfc.nfvo.emsdriver.collector.alarm.AlarmTaskThread;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
public class AlarmTaskThreadTest {
private AlarmTaskThread taskThread;
+ private AlarmSocketServer server;
@Before
public void setUp() throws IOException {
- taskThread = new AlarmTaskThread();
+ new Thread(){
+ public void run(){
+ server = new AlarmSocketServer();
+ server.socketServer();
+ }
+ }.start();
+
+ CollectVo collectVo = new CollectVo();
+ collectVo.setIP("127.0.0.1");
+ collectVo.setPort("12345");
+ collectVo.setUser("user");
+ collectVo.setPassword("12345");
+ taskThread = new AlarmTaskThread(collectVo);
}
@Test
public void build120Alarm(){
String alarm = "{\"alarmSeq\":495,\"alarmTitle\":\"LTE cell outage\",\"alarmStatus\":1,\"alarmType\":\"processingErrorAlarm\"}";
-// String al = taskThread.build120Alarm(alarm);
+ try {
+ new Thread(){
+ public void run(){
+ try {
+ Thread.sleep(3000);
+
+ server.stop();
+ taskThread.setStop(true);
+ taskThread.close();
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ }.start();
+
+ taskThread.init();
+ taskThread.receive();
+
+
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
assertNotNull(alarm);
}
--- /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.collector.alarm;
+
+import static org.junit.Assert.assertNotNull;
+
+import org.junit.Test;
+
+public class MessageUtilTest {
+
+ @Test
+ public void putLoginFtp(){
+ Msg msg = MessageUtil.putLoginFtp("user", "passwd");
+
+ assertNotNull(msg);
+ }
+ @Test
+ public void putSyncMsg(){
+ Msg msg = MessageUtil.putSyncMsg(1, 10);
+
+ assertNotNull(msg);
+ }
+
+ @Test
+ public void reqSyncAlarmFile(){
+ Msg msg = MessageUtil.reqSyncAlarmFile(1, "2017-10-7","2017-10-7");
+
+ assertNotNull(msg);
+ }
+ @Test
+ public void reqSyncAlarmFileByAlarmSeq(){
+ Msg msg = MessageUtil.reqSyncAlarmFileByAlarmSeq(1, 12);
+
+ assertNotNull(msg);
+ }
+ @Test
+ public void reqSyncAlarmFileByTime(){
+ Msg msg = MessageUtil.reqSyncAlarmFileByTime(1, "2017-10-7","2017-10-7");
+
+ assertNotNull(msg);
+ }
+
+ @Test
+ public void closeConnAlarmMsg(){
+ Msg msg = MessageUtil.closeConnAlarmMsg();
+
+ assertNotNull(msg);
+ }
+
+
+
+
+
+
+
+
+
+}
--- /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.ftp;
+
+import static org.junit.Assert.assertNotNull;
+
+import org.apache.commons.net.ftp.FTPClient;
+import org.apache.commons.net.ftp.FTPFile;
+import org.junit.Before;
+import org.junit.Test;
+
+public class AFtpRemoteFileTest {
+
+ AFtpRemoteFile aFtpRemoteFile = null;
+ @Before
+ public void setUp() {
+ FTPFile f = new FTPFile();
+ f.setName("aaa/bb.txt");
+ aFtpRemoteFile = new AFtpRemoteFile(f , new FTPClient(), "aaa/");
+ }
+
+ @Test
+ public void getFileName() {
+ String fileName = aFtpRemoteFile.getFileName();
+ assertNotNull(fileName);
+ }
+ @Test
+ public void getAbsFileName() {
+ String absFileName = aFtpRemoteFile.getAbsFileName();
+ assertNotNull(absFileName);
+ }
+
+}
--- /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.ftp;
+
+public class FTPSrvTest {
+
+}
--- /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.service;
+
+import org.junit.Test;
+
+public class CommandResourceTest {
+
+ @Test
+ public void testExecuteCommand(){
+ CommandResource commandResource = new CommandResource();
+ commandResource.executeCommand("aaa");
+ }
+}
+
*/
package org.onap.vfc.nfvo.emsdriver.serviceregister;
+import java.util.List;
+
import org.junit.Before;
import org.junit.Test;
import org.onap.vfc.nfvo.emsdriver.serviceregister.model.MsbRegisterVo;
MsbRegisterVo registerInfo = new MsbRegisterVo();
registerInfo.setServiceName("ems-driver");
registerInfo.setUrl("/api/emsdriver/v1");
- String registerResponse = MsbRestServiceProxy.registerService(registerInfo);
- System.out.println(registerResponse);
+ MsbRestServiceProxy.registerService(registerInfo);
+ }
+ @Test
+ public void testunRegiserService(){
+ MsbRestServiceProxy.unRegiserService("emsdriver","v1","172.0.0.1","9999");
+ }
+
+ @Test
+ public void testqueryService(){
+ List<String> queryService = MsbRestServiceProxy.queryService("emsdriver","v1");
}
}
Code Review / vfc / nfvo / driver / ems.git / commitdiff