import org.quartz.SimpleTrigger;\r
import org.quartz.impl.StdSchedulerFactory;\r
\r
+import java.math.BigDecimal;\r
import java.util.Arrays;\r
import java.util.HashMap;\r
import java.util.List;\r
final String jsonPath =\r
"$.event.measurementsForVfScalingFields.vNicPerformanceArray[*].receivedBroadcastPacketsAccumulated";\r
final ImmutableSet<String> fieldPaths = ImmutableSet.of(jsonPath);\r
- final Map<String, List<Long>> jsonPathValueMap = TCAUtils.getJsonPathValue(cefMessageString, fieldPaths);\r
- assertThat("Json Path value must match", jsonPathValueMap.get(jsonPath).get(0), is(5000L));\r
+ final Map<String, List<BigDecimal>> jsonPathValueMap = TCAUtils.getJsonPathValue(cefMessageString, fieldPaths);\r
+ assertThat("Json Path value must match",\r
+ jsonPathValueMap.get(jsonPath).get(0), is(new BigDecimal(5000)));\r
\r
}\r
\r
final String cefMessageString = fromStream(CEF_MESSAGE_JSON_FILE_LOCATION);\r
final String jsonPath = "$.event.measurementsForVfScalingFields.vNicPerformanceArray[*].invalid";\r
final ImmutableSet<String> fieldPaths = ImmutableSet.of(jsonPath);\r
- final Map<String, List<Long>> jsonPathValueMap = TCAUtils.getJsonPathValue(cefMessageString, fieldPaths);\r
+ final Map<String, List<BigDecimal>> jsonPathValueMap = TCAUtils.getJsonPathValue(cefMessageString, fieldPaths);\r
assertThat("Json path value must be empty", jsonPathValueMap.size(), is(0));\r
\r
}\r
violatedThreshold.setSeverity(severity);\r
violatedThreshold.setDirection(Direction.GREATER);\r
violatedThreshold.setClosedLoopControlName("violatedThresholdClosedLoopName");\r
- violatedThreshold.setActualFieldValue(100L);\r
+ violatedThreshold.setActualFieldValue(new BigDecimal(100L));\r
violatedThreshold.setFieldPath("violatedThresholdFieldPath");\r
violatedThreshold.setVersion("violatedThresholdVersion");\r
violatedThreshold.setClosedLoopEventStatus(ClosedLoopEventStatus.ONSET);\r