NorthboundRunTest.java 文件源码

@Then("^flows dump contains (\\d+) flows$")
public void checkDumpFlows(final int flowCount) {
    List<FlowPayload> flows = FlowUtils.getFlowDump();
    assertNotNull(flows);
    flows.forEach(flow -> System.out.println(flow.getId()));
    assertEquals(flowCount, flows.size());
}