src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java

   1 package org.onap.aai.sparky.dal.aai;\r
   2 \r
   3 import org.junit.Assert;\r
   4 import org.junit.Test;\r
   5 import org.onap.aai.sparky.dal.NetworkTransaction;\r
   6 import org.onap.aai.sparky.dal.rest.HttpMethod;\r
   7 import org.onap.aai.sparky.dal.rest.OperationResult;\r
   8 \r
   9 public class ActiveInventoryProcessingExceptionStatisticsTest {\r
  10 \r
  11 \r
  12   @Test\r
  13   public void testUpdateCounters() {\r
  14     ActiveInventoryProcessingExceptionStatistics aipes =\r
  15         new ActiveInventoryProcessingExceptionStatistics();\r
  16 \r
  17     aipes.incrementCounter("NativeSocketConnectException", 1);\r
  18     aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
  19     aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
  20     aipes.incrementCounter("JerseyClientTimoutException", 1);\r
  21     aipes.incrementCounter("UnknownException", 1);\r
  22 \r
  23     OperationResult result = new OperationResult();\r
  24     result.setResultCode(310);\r
  25     result.setResult("java.net.SocketTimeoutException: connect timed out");\r
  26     result.setNumRequestRetries(1);\r
  27     NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  28     aipes.updateCounters(ntwTxn1);\r
  29 \r
  30     result.setResult("result-1");\r
  31     NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  32     aipes.updateCounters(ntwTxn2);\r
  33 \r
  34     result.setResult("java.net.ConnectException: Connection timed out: connect");\r
  35     NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  36     aipes.updateCounters(ntwTxn3);\r
  37 \r
  38     result.setResult("java.net.ConnectException: Connection refused: connect");\r
  39     NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  40     aipes.updateCounters(ntwTxn4);\r
  41 \r
  42     result.setResult("java.net.SocketException: Connection reset");\r
  43     NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  44     aipes.updateCounters(ntwTxn5);\r
  45 \r
  46   }\r
  47 \r
  48   @Test\r
  49   public void testGetStatisticsReport() {\r
  50     ActiveInventoryProcessingExceptionStatistics aipes =\r
  51         new ActiveInventoryProcessingExceptionStatistics();\r
  52 \r
  53     aipes.incrementCounter("NativeSocketConnectException", 1);\r
  54     aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
  55     aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
  56     aipes.incrementCounter("JerseyClientTimoutException", 1);\r
  57     aipes.incrementCounter("UnknownException", 1);\r
  58 \r
  59     String statReport = aipes.getStatisticsReport();\r
  60     Assert.assertNotNull(statReport);\r
  61   }\r
  62 }\r