"server.ssl.key-store=./config/keystore.jks", //
"app.webclient.trust-store=./config/truststore.jks", //
"app.configuration-filepath=./src/test/resources/test_application_configuration.json", //
- "app.pm-files-path=./src/test/resources/" //
+ "app.pm-files-path=./src/test/resources/", //
+ "app.auth-token-file=src/test/resources/jwtToken.b64", //
+ "app.kafka.use-oath-token=false" //
}) //
class Integration {
props.put(ProducerConfig.ACKS_CONFIG, "all");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
+ this.applicationConfig.addKafkaSecurityProps(props);
return SenderOptions.create(props);
}
final String PM_REPORT_FILE_BIG = "./src/test/resources/A20000626.2315+0200-2330+0200_HTTPS-6-73.json";
final String PM_REPORT_FILE = "./src/test/resources/pm_report.json";
+ /**
+ * Generate a PM report
+ *
+ * @param sequenceValue used for generating counter values
+ * @param noOfObjects used for generating counter values
+ * @return
+ */
String pmReport(int sequenceValue, int noOfObjects) {
try {
String str = Files.readString(Path.of(PM_REPORT_FILE), Charset.defaultCharset());
}
+ // Store PM data for 24 hours in influx. The the data contains genenerated
+ // counter values
+ // that varies over time.
@Test
void testStoreReportsInflux() throws Exception {
final int NO_OF_OBJECTS = 24 * 4;