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 = new ActiveInventoryProcessingExceptionStatistics();\r
  15                 \r
  16                 aipes.incrementCounter("NativeSocketConnectException", 1);\r
  17                 aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
  18                 aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
  19                 aipes.incrementCounter("JerseyClientTimoutException", 1);\r
  20                 aipes.incrementCounter("UnknownException", 1);\r
  21                 \r
  22                 OperationResult result = new OperationResult();\r
  23                 result.setResultCode(310);\r
  24                 result.setResult("java.net.SocketTimeoutException: connect timed out");\r
  25                 result.setNumRequestRetries(1);\r
  26                 NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  27                 aipes.updateCounters(ntwTxn1);\r
  28                 \r
  29                 result.setResult("result-1");\r
  30                 NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  31                 aipes.updateCounters(ntwTxn2);\r
  32                 \r
  33                 result.setResult("java.net.ConnectException: Connection timed out: connect");           \r
  34                 NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  35                 aipes.updateCounters(ntwTxn3);\r
  36                 \r
  37                 result.setResult("java.net.ConnectException: Connection refused: connect");             \r
  38                 NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  39                 aipes.updateCounters(ntwTxn4);\r
  40                 \r
  41                 result.setResult("java.net.SocketException: Connection reset");         \r
  42                 NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
  43                 aipes.updateCounters(ntwTxn5);\r
  44                 \r
  45         }\r
  46         \r
  47         @Test\r
  48         public void testGetStatisticsReport() {\r
  49                 ActiveInventoryProcessingExceptionStatistics aipes = new ActiveInventoryProcessingExceptionStatistics();\r
  50                 \r
  51                 aipes.incrementCounter("NativeSocketConnectException", 1);\r
  52                 aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
  53                 aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
  54                 aipes.incrementCounter("JerseyClientTimoutException", 1);\r
  55                 aipes.incrementCounter("UnknownException", 1);\r
  56                 \r
  57                 String statReport = aipes.getStatisticsReport();\r
  58                 Assert.assertNotNull(statReport);\r
  59         }\r
  60 }\r