@Test
public void testOpenInterruption() throws IOException, InterruptedException {

  EventSink snk = new BackOffFailOverSink(InterruptSinks.openSink(),
      new NullSink());
  try {
    snk.open();
  } catch (InterruptedException ie) {
    // if interrupted, it should be closed.
    return;
  }
  fail("expected interruption!");
}