+ @Test
+ public void testGetEvents() {
+ EventHandlerImpl adapter = new EventHandlerImpl(properties);
+ Consumer consumer = Mockito.mock(Consumer.class);
+ Mockito.when(consumer.fetch(Mockito.anyInt(), Mockito.anyInt()))
+ .thenReturn(new ArrayList<String>(Arrays.asList("TEST1")));
+ Whitebox.setInternalState(adapter, "reader", consumer);
+ assertEquals("TEST1", adapter.getIncomingEvents().get(0));
+ }
+
+ @Test
+ public void testGetEventsClass() {
+ EventHandlerImpl adapter = new EventHandlerImpl(properties);
+ Consumer consumer = Mockito.mock(Consumer.class);
+ Mockito.when(consumer.fetch(Mockito.anyInt(), Mockito.anyInt()))
+ .thenReturn(new ArrayList<String>(Arrays.asList("1")));
+ Whitebox.setInternalState(adapter, "reader", consumer);
+ assertEquals(Integer.valueOf(1), adapter.getIncomingEvents(Integer.class).get(0));
+ }
+
+ @Test
+ public void testSetters() {
+ EventHandlerImpl adapter = new EventHandlerImpl(properties);
+ adapter.setResponseProblemBlacklistTime("1");
+ assertEquals("1", Whitebox.getInternalState(adapter, "responseProblemBlacklistTime"));
+ adapter.setServerProblemBlacklistTime("1");
+ assertEquals("1", Whitebox.getInternalState(adapter, "serverProblemBlacklistTime"));
+ adapter.setDnsIssueBlacklistTime("1");
+ assertEquals("1", Whitebox.getInternalState(adapter, "dnsIssueBlacklistTime"));
+ adapter.setIOExceptionBlacklistTime("1");
+ assertEquals("1", Whitebox.getInternalState(adapter, "ioExceptionBlacklistTime"));
+ }