### Question:
ContinuousChangesFeed implements ChangesFeed, Runnable { public boolean isAlive() { return thread.isAlive(); } ContinuousChangesFeed(String dbName, HttpResponse httpResponse); DocumentChange next(); DocumentChange poll(); DocumentChange next(long timeout, TimeUnit unit); void cancel(); boolean isAlive(); int queueSize(); void run();  }### Answer:
@Test @Ignore("fails intermittently") public void when_exception_occurrs_all_threads_should_be_interrupted() throws IOException, InterruptedException { Consumer c = new Consumer(); c.feed = feed; Thread t = new Thread(c); t.setName("consumer-thread"); t.start(); writeChange(); c.awaitActivity(); writeHeartbeat(); writeChange(); c.awaitActivity(); testStream.throwException = true; try { writeHeartbeat(); } catch (IOException e) { } c.awaitTermination(); assertFalse(t.isAlive()); assertFalse(feed.isAlive()); }