@Test public void patternLookupShouldBeCaseSensitive() { when(record.getPayload()).thenReturn("JAVA rocks!"); assertThat(grepFilter.processRecord(record)).isNull(); }
@Override public Record<String> processRecord(Record<String> record) { String payload = record.getPayload(); if (!payload.contains(pattern)) { return null; } return record; }
GrepFilter implements RecordFilter<String> { @Override public Record<String> processRecord(Record<String> record) { String payload = record.getPayload(); if (!payload.contains(pattern)) { return null; } return record; } }
GrepFilter implements RecordFilter<String> { @Override public Record<String> processRecord(Record<String> record) { String payload = record.getPayload(); if (!payload.contains(pattern)) { return null; } return record; } GrepFilter(final String pattern); }
GrepFilter implements RecordFilter<String> { @Override public Record<String> processRecord(Record<String> record) { String payload = record.getPayload(); if (!payload.contains(pattern)) { return null; } return record; } GrepFilter(final String pattern); @Override Record<String> processRecord(Record<String> record); }
GrepFilter implements RecordFilter<String> { @Override public Record<String> processRecord(Record<String> record) { String payload = record.getPayload(); if (!payload.contains(pattern)) { return null; } return record; } GrepFilter(final String pattern); @Override Record<String> processRecord(Record<String> record);  }