@Test public void corruptPoll() { IntentStoreDelegate mockDelegate = new IntentStoreDelegate() { @Override public void process(IntentData intentData) { intentData.setState(CORRUPT); store.write(intentData); } @Override public void notify(IntentEvent event) {} }; store.setDelegate(mockDelegate); Intent intent = new MockIntent(1L); Timestamp version = new SystemClockTimestamp(1L); IntentData data = new IntentData(intent, INSTALL_REQ, version); store.addPending(data); cleanup.run(); assertEquals("Expect number of submits incorrect", 1, service.submitCounter()); }
@Override public void run() { try { cleanup(); } catch (Exception e) { log.warn("Caught exception during Intent cleanup", e); } }
IntentCleanup implements Runnable, IntentListener { @Override public void run() { try { cleanup(); } catch (Exception e) { log.warn("Caught exception during Intent cleanup", e); } } }
IntentCleanup implements Runnable, IntentListener { @Override public void run() { try { cleanup(); } catch (Exception e) { log.warn("Caught exception during Intent cleanup", e); } }  }
IntentCleanup implements Runnable, IntentListener { @Override public void run() { try { cleanup(); } catch (Exception e) { log.warn("Caught exception during Intent cleanup", e); } }  @Activate void activate(); @Deactivate void deactivate(); @Modified void modified(ComponentContext context); @Override void run(); @Override void event(IntentEvent event); }
IntentCleanup implements Runnable, IntentListener { @Override public void run() { try { cleanup(); } catch (Exception e) { log.warn("Caught exception during Intent cleanup", e); } }  @Activate void activate(); @Deactivate void deactivate(); @Modified void modified(ComponentContext context); @Override void run(); @Override void event(IntentEvent event);  }