public void process()

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