6 package org.opendaylight.mwtn.dcaeConnector.test;
8 import org.opendaylight.mwtn.config.impl.DcaeConfig;
9 import org.opendaylight.mwtn.dcaeConnector.impl.DcaeMessages;
10 import org.opendaylight.mwtn.dcaeConnector.impl.DcaeSenderImpl;
12 public class DcaeTestClient {
14 private static final boolean TESTCOLLECTOR_YES = true;
16 public static void main(String[] args) {
18 System.out.println("Test program to verify DCAE https connectivity");
21 DcaeConfig configuration = DcaeConfig.getDefaultConfiguration();
23 if (configuration != null) {
26 System.out.println("Configuration: "+configuration);
28 DcaeSenderImpl dcaeClient = new DcaeSenderImpl(configuration.getEventReveicerUrl(), configuration.getUserCredentials());
30 if (TESTCOLLECTOR_YES) {
31 System.out.println("Connect to testclient and send notifications");
33 DcaeMessages dcaeMessages = new DcaeMessages(dcaeClient, "ControllerName", 31, null);
35 for (int t=0; t < 2; t++) {
37 Thread.sleep(1000); //1000 milliseconds is one second.
38 } catch(InterruptedException ex) {
39 Thread.currentThread().interrupt();
41 System.out.println(t+". Send notification and receive answer message");
42 System.out.println("Heartbeat message: "+dcaeMessages.postHeartBeat());
43 System.out.println("Status of ECOMP Client: "+dcaeClient.getStatusAsString());
48 System.out.println("Connect to server and receive initial answer.");
49 System.out.println("Message: "+dcaeClient.testConnectServer());