@Test public void testReadClob() throws Exception { Context context = new Context(); context.put(MorphlineHandlerImpl.MORPHLINE_FILE_PARAM, RESOURCES_DIR + "/test-morphlines/readClob.conf"); Event input = EventBuilder.withBody("foo", Charsets.UTF_8); input.getHeaders().put("name", "nadja"); Event actual = build(context).intercept(input); Event expected = EventBuilder.withBody(null, ImmutableMap.of("name", "nadja", Fields.MESSAGE, "foo")); assertEqualsEvent(expected, actual); List<Event> actualList = build(context).intercept(Collections.singletonList(input)); List<Event> expectedList = Collections.singletonList(expected); assertEqualsEventList(expectedList, actualList); }
@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);  }