mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedEventFilter.java [45:72]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                List<String> terms = new ArrayList<String>();
                if (clientId != null && !clientId.isEmpty()) {
                    terms.add(clientId + "_" + subId);
                } else {
                    terms.add(subId);
                }
                filter = new SourceEventFilter(terms);
            }
            return filter;
        }
        return filter;
    }

    private static class SourceEventFilter implements Func1<TaggedData, Boolean> {

        private String jobId = "UNKNOWN";
        private String jobName = "UNKNOWN";
        private List<String> terms;

        SourceEventFilter(List<String> terms) {
            this.terms = terms;
            String jId = MantisProperties.getProperty("JOB_ID");
            if (jId != null && !jId.isEmpty()) {
                jobId = jId;
            }
            String jName = MantisProperties.getProperty("JOB_NAME");
            if (jName != null && !jName.isEmpty()) {
                jobName = jName;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedEventFilter.java [40:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                List<String> terms = new ArrayList<String>();
                if (clientId != null && !clientId.isEmpty()) {
                    terms.add(clientId + "_" + subId);
                } else {
                    terms.add(subId);
                }
                filter = new SourceEventFilter(terms);
            }
            return filter;
        }
        return filter;
    }

    private static class SourceEventFilter implements Func1<TaggedData, Boolean> {

        private String jobId = "UNKNOWN";
        private String jobName = "UNKNOWN";
        private List<String> terms;

        SourceEventFilter(List<String> terms) {
            this.terms = terms;
            String jId = MantisProperties.getProperty("JOB_ID");
            if (jId != null && !jId.isEmpty()) {
                jobId = jId;
            }
            String jName = MantisProperties.getProperty("JOB_NAME");
            if (jName != null && !jName.isEmpty()) {
                jobName = jName;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -