public void process()

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;
            }
        }
    }