private static final String PM_NOTIFICATIONS = "PM_Notification";
static CommonEventHeader toCommonEventHeader(final VesMappingConfiguration config, final String hostIp,
private static final String PM_NOTIFICATIONS = "PM_Notification";
static CommonEventHeader toCommonEventHeader(final VesMappingConfiguration config, final String hostIp,
- final CsvConfiguration csv, final Map<String, String> record, final int sequence) {
+ final CsvConfiguration csv, final Map<String, String> recordMap, final int sequence) {
- setMandatoryFields(config, hostIp, csv, header, record, sequence);
+ setMandatoryFields(config, hostIp, csv, header, recordMap, sequence);
- final CsvConfiguration csv, final CommonEventHeader header, final Map<String, String> record,
+ final CsvConfiguration csv, final CommonEventHeader header, final Map<String, String> recordMap,
final int sequence) {
header.setDomain(CommonEventHeader.Domain.MEASUREMENT);
header.setEventName(CommonEventHeader.Domain.FAULT.name()
final int sequence) {
header.setDomain(CommonEventHeader.Domain.MEASUREMENT);
header.setEventName(CommonEventHeader.Domain.FAULT.name()
header.setReportingEntityName(config.getReportingEntityName());
header.setSequence((long) sequence);
final String sourceNameField = csv.getSourceName();
header.setReportingEntityName(config.getReportingEntityName());
header.setSequence((long) sequence);
final String sourceNameField = csv.getSourceName();
final Optional<String> optRegex = Optional.ofNullable(csv.getSourceNameRegex());
header.setSourceName(optRegex.map(regex -> sourceNameRecordValue.replaceAll(regex, ""))
.orElse(sourceNameRecordValue));
final Optional<String> optRegex = Optional.ofNullable(csv.getSourceNameRegex());
header.setSourceName(optRegex.map(regex -> sourceNameRecordValue.replaceAll(regex, ""))
.orElse(sourceNameRecordValue));
.collect(Collectors.joining());
header.setEventId(UUID.nameUUIDFromBytes(keyIdConcat.getBytes(StandardCharsets.UTF_8)).toString());
}
.collect(Collectors.joining());
header.setEventId(UUID.nameUUIDFromBytes(keyIdConcat.getBytes(StandardCharsets.UTF_8)).toString());
}