	@Test
	public void testClose() throws ProducerException, InterruptedException {

		LogProducerProvider producerProvider = new LogProducerProvider(
				"test-project", "test-endpoint", "test-ak", "test-secret", 1, 100);

		LogProducer producer = Mockito.mock(LogProducer.class);
		Whitebox.setInternalState(producerProvider, "client", producer);

		Mockito.doThrow(new InterruptedException()).doNothing().when(producer).close();
		producerProvider.closeClient();

		Mockito.verify(producer, Mockito.times(2)).close();
	}