5e00bd87c752c03830d564fe7a1e9d2992d96b70
[ccsdk/apps.git] / sdnr / wireless-transport / code-Carbon-SR1 / apps / devicemanager / impl / src / main / java / org / opendaylight / mwtn / dcaeConnector / test / DcaeTestClient.java
1 /**
2  *
3  * @author herbert
4  *
5  */
6 package org.opendaylight.mwtn.dcaeConnector.test;
7
8 import org.opendaylight.mwtn.config.impl.DcaeConfig;
9 import org.opendaylight.mwtn.dcaeConnector.impl.DcaeMessages;
10 import org.opendaylight.mwtn.dcaeConnector.impl.DcaeSenderImpl;
11
12 public class DcaeTestClient {
13
14     private static final boolean TESTCOLLECTOR_YES = true;
15
16         public static void main(String[] args) {
17
18         System.out.println("Test program to verify DCAE https connectivity");
19
20         //Get configuration
21         DcaeConfig configuration = DcaeConfig.getDefaultConfiguration();
22
23         if (configuration != null) {
24
25             //Start services
26             System.out.println("Configuration: "+configuration);
27
28             DcaeSenderImpl dcaeClient = new DcaeSenderImpl(configuration.getEventReveicerUrl(), configuration.getUserCredentials());
29
30             if (TESTCOLLECTOR_YES) {
31                 System.out.println("Connect to testclient and send notifications");
32
33                 DcaeMessages dcaeMessages = new DcaeMessages(dcaeClient, "ControllerName", 31, null);
34
35                 for (int t=0; t < 2; t++) {
36                     try {
37                         Thread.sleep(1000);                 //1000 milliseconds is one second.
38                     } catch(InterruptedException ex) {
39                         Thread.currentThread().interrupt();
40                     }
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());
44                 }
45
46             } else {
47
48                 System.out.println("Connect to server and receive initial answer.");
49                 System.out.println("Message: "+dcaeClient.testConnectServer());
50
51             }
52
53         }
54    }
55
56 }