@Test
public void createsBatchListener() {

    // given
    BatchEmitterFactory factory = new BulkEmitterFactory();
    HCHttp clientObjectFactory = Mockito.spy(createDefaultHttpObjectFactoryBuilder().build());
    NoopFailoverPolicy failoverPolicy = new NoopFailoverPolicy();
    // when
    factory.createInstance(1, 1, clientObjectFactory, failoverPolicy);
    // then
    Mockito.verify(clientObjectFactory).createBatchListener(eq(failoverPolicy));
}