in src/main/java/com/amazonaws/kvstranscribestreaming/KVSContactTagProcessor.java [28:40]
public void process(MkvTag mkvTag, Optional<FragmentMetadata> currentFragmentMetadata) {
if ("ContactId".equals(mkvTag.getTagName())) {
if (contactId.equals(mkvTag.getTagValue())) {
sameContact = true;
}
else {
logger.info("Contact Id in tag does not match expected, will stop streaming. "
+ "contact id: %s, expected: %s",
mkvTag.getTagValue(), contactId);
sameContact = false;
}
}
}