OFRendererFlowManagerProvider implements OFRendererFlowService, Observer, AutoCloseable { @Override public void pushIntentFlow(final Intent intent, final FlowAction flowAction) { LOG.info("\nIntent: {}, FlowAction: {}", intent.toString(), flowAction.getValue()); if (intent.getQosConfig() != null) { return; } try { ActionStrategy actionStrategy = new DefaultExecutor(intentFlowManager, dataBroker); actionStrategy.execute(intent, flowAction); } catch (IntentInvalidException ie) { } } OFRendererFlowManagerProvider(final DataBroker dataBroker,
                                         final PipelineManager pipelineManager,
                                         final IdManagerService idManagerService); @Override void start(); @Override void pushIntentFlow(final Intent intent, final FlowAction flowAction); @Override void pushARPFlow(final NodeId nodeId, final FlowAction flowAction); @Override void close(); @Override void pushLLDPFlow(final NodeId nodeId, final FlowAction flowAction); @Override synchronized Dataflow pushDataFlow(Dataflow dataFlow); Dataflow sendDataflow(final Dataflow dataflow); @Override void pushDataFlow(final NodeId nodeId, final Dataflow dataflow); @Override MeterId createMeter(final String id, final long dropRate); @Override void removeMeter(final Long meterId, final String dataflowId); @Override void update(); @Override void setSubject(final Subject sub); @Override void stop();  }
@Test public void testPushIntentFlowWithQoSConfiguration() throws IntentInvalidException { ofRendererFlowManagerProvider.pushIntentFlow(intent, flowAction); }