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 }