@Test public void testGrokIfNotMatchDropEventDrop() throws Exception { Context context = new Context(); context.put(MorphlineHandlerImpl.MORPHLINE_FILE_PARAM, RESOURCES_DIR + "/test-morphlines/grokIfNotMatchDropRecord.conf"); String msg = "<XXXXXXXXXXXXX164>Feb 4 10:46:14 syslog sshd[607]: Server listening on 0.0.0.0 port 22."; Event input = EventBuilder.withBody(null, ImmutableMap.of(Fields.MESSAGE, msg)); Event actual = build(context).intercept(input); assertNull(actual); }
@Override public List<Event> intercept(List<Event> events) { LocalMorphlineInterceptor interceptor = borrowFromPool(); List<Event> results = interceptor.intercept(events); returnToPool(interceptor); return results; }
MorphlineInterceptor implements Interceptor { @Override public List<Event> intercept(List<Event> events) { LocalMorphlineInterceptor interceptor = borrowFromPool(); List<Event> results = interceptor.intercept(events); returnToPool(interceptor); return results; } }
MorphlineInterceptor implements Interceptor { @Override public List<Event> intercept(List<Event> events) { LocalMorphlineInterceptor interceptor = borrowFromPool(); List<Event> results = interceptor.intercept(events); returnToPool(interceptor); return results; } protected  MorphlineInterceptor(Context context); }
MorphlineInterceptor implements Interceptor { @Override public List<Event> intercept(List<Event> events) { LocalMorphlineInterceptor interceptor = borrowFromPool(); List<Event> results = interceptor.intercept(events); returnToPool(interceptor); return results; } protected  MorphlineInterceptor(Context context); @Override void initialize(); @Override void close(); @Override List<Event> intercept(List<Event> events); @Override Event intercept(Event event); }
MorphlineInterceptor implements Interceptor { @Override public List<Event> intercept(List<Event> events) { LocalMorphlineInterceptor interceptor = borrowFromPool(); List<Event> results = interceptor.intercept(events); returnToPool(interceptor); return results; } protected  MorphlineInterceptor(Context context); @Override void initialize(); @Override void close(); @Override List<Event> intercept(List<Event> events); @Override Event intercept(Event event);  }