thread.start();
while (!writerQueue.isEmpty()) {
Thread.yield();
}
thread.terminate();
<BUG>thread.join();
}</BUG>
@Test
public void testBlocking() throws Exception {
final Configuration configuration = new Configuration();

thread.start();
while (!writerQueue.isEmpty()) {
Thread.yield();
}
thread.terminate();
thread.join(THREAD_STATE_CHANGE_TIMEOUT_IN_MS);
Assert.assertThat(thread.getState(), CoreMatchers.is(State.TERMINATED));
}
@Test
public void testBlocking() throws Exception {
final Configuration configuration = new Configuration();
