@Test(expected = Exception.class)
public void close_throws_if_service_doesnt_shutdown() throws Exception {

  when(service.awaitTermination(anyLong(), any())).thenReturn(false);
  new Sender(onrampClient, contextManager, 1L, service).close();
}