@Ignore("skipping until we fix update ordering problem") @Test public void errorIntentInstallFromFlows() { final Long id = MockIntent.nextId(); flowRuleService.setFuture(false); MockIntent intent = new MockIntent(id); listener.setLatch(1, Type.FAILED); listener.setLatch(1, Type.INSTALL_REQ); service.submit(intent); listener.await(Type.INSTALL_REQ); listener.await(Type.FAILED); verifyState(); }
@Override public void submit(Intent intent) { checkPermission(INTENT_WRITE); checkNotNull(intent, INTENT_NULL); IntentData data = new IntentData(intent, IntentState.INSTALL_REQ, null); store.addPending(data); }
IntentManager extends AbstractListenerManager<IntentEvent, IntentListener> implements IntentService, IntentExtensionService { @Override public void submit(Intent intent) { checkPermission(INTENT_WRITE); checkNotNull(intent, INTENT_NULL); IntentData data = new IntentData(intent, IntentState.INSTALL_REQ, null); store.addPending(data); } }
IntentManager extends AbstractListenerManager<IntentEvent, IntentListener> implements IntentService, IntentExtensionService { @Override public void submit(Intent intent) { checkPermission(INTENT_WRITE); checkNotNull(intent, INTENT_NULL); IntentData data = new IntentData(intent, IntentState.INSTALL_REQ, null); store.addPending(data); }  }
IntentManager extends AbstractListenerManager<IntentEvent, IntentListener> implements IntentService, IntentExtensionService { @Override public void submit(Intent intent) { checkPermission(INTENT_WRITE); checkNotNull(intent, INTENT_NULL); IntentData data = new IntentData(intent, IntentState.INSTALL_REQ, null); store.addPending(data); }  @Activate void activate(); @Deactivate void deactivate(); @Modified void modified(ComponentContext context); @Override void submit(Intent intent); @Override void withdraw(Intent intent); @Override void purge(Intent intent); @Override Intent getIntent(Key key); @Override Iterable<Intent> getIntents(); @Override Iterable<IntentData> getIntentData(); @Override long getIntentCount(); @Override IntentState getIntentState(Key intentKey); @Override List<Intent> getInstallableIntents(Key intentKey); @Override boolean isLocal(Key intentKey); @Override void registerCompiler(Class<T> cls, IntentCompiler<T> compiler); @Override void unregisterCompiler(Class<T> cls); @Override Map<Class<? extends Intent>, IntentCompiler<? extends Intent>> getCompilers(); @Override Iterable<Intent> getPending(); }
IntentManager extends AbstractListenerManager<IntentEvent, IntentListener> implements IntentService, IntentExtensionService { @Override public void submit(Intent intent) { checkPermission(INTENT_WRITE); checkNotNull(intent, INTENT_NULL); IntentData data = new IntentData(intent, IntentState.INSTALL_REQ, null); store.addPending(data); }  @Activate void activate(); @Deactivate void deactivate(); @Modified void modified(ComponentContext context); @Override void submit(Intent intent); @Override void withdraw(Intent intent); @Override void purge(Intent intent); @Override Intent getIntent(Key key); @Override Iterable<Intent> getIntents(); @Override Iterable<IntentData> getIntentData(); @Override long getIntentCount(); @Override IntentState getIntentState(Key intentKey); @Override List<Intent> getInstallableIntents(Key intentKey); @Override boolean isLocal(Key intentKey); @Override void registerCompiler(Class<T> cls, IntentCompiler<T> compiler); @Override void unregisterCompiler(Class<T> cls); @Override Map<Class<? extends Intent>, IntentCompiler<? extends Intent>> getCompilers(); @Override Iterable<Intent> getPending();  }