@Test
public void testInterrupt() throws Exception {

  testTransact(TestChannel.Mode.SLEEP, InterruptedException.class,
      new Runnable() {
        @Override
        public void run() {
          interruptTest(new Runnable() {
              @Override
              public void run() {
                channel.put(events.get(0));
              }
            });
        }
    });
}