import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
+import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.TimeUnit;
private ClientResponse response;
private IseSourceConfig config;
+ private IseContext iseContext;
private GbpIseSgtHarvesterImpl harvester;
.build())
.build();
+ iseContext = new IseContext(config);
harvester = new GbpIseSgtHarvesterImpl(processor);
}
Mockito.when(processor.processSgtInfo(Matchers.eq(TENANT_ID), Matchers.<List<SgtInfo>>any())).thenReturn(
Futures.immediateCheckedFuture(null));
- final ListenableFuture<Integer> harvestResult = harvester.harvest(config);
+ final ListenableFuture<Collection<SgtInfo>> harvestResult = harvester.harvestAll(iseContext);
final InOrder inOrder = Mockito.inOrder(client, webResource, builder);
inOrder.verify(client).resource(ISE_REST_URL.getValue());
inOrder.verify(builder).get(ClientResponse.class);
inOrder.verifyNoMoreInteractions();
- final Integer count = harvestResult.get(2, TimeUnit.SECONDS);
- Assert.assertEquals(1, count.intValue());
+ final Collection<SgtInfo> count = harvestResult.get(2, TimeUnit.SECONDS);
+ Assert.assertEquals(1, count.size());
}
}
\ No newline at end of file