@Test
public void testLogstashAppender() throws InterruptedException {

    MockEndpoint events = getMockEndpoint("mock:events");
    events.expectedMessageCount(1);
    appender.doAppend(MockEvents.createInfoEvent());
    assertMockEndpointsSatisfied();
}