in src/main/java/com/amazonaws/kvstranscribestreaming/streaming/KVSTransactionIdTagProcessor.java [26:37]
public void process(MkvTag mkvTag, Optional<FragmentMetadata> currentFragmentMetadata) {
if ("TransactionId".equals(mkvTag.getTagName())) {
if (this.transactionId.equals(mkvTag.getTagValue())) {
sameTransactionId = true;
}
else {
log.info("TransactionId Id in tag does not match expected, will stop streaming. "
+ "transactionId actual:" + mkvTag.getTagValue() + " expected: {}" + transactionId);
sameTransactionId = false;
}
}
}