class ReactiveFlowWriter implements ArpPacketListener {

    public void writeFlows(NodeConnectorRef ingress, MacAddress srcMac, MacAddress destMac) {
        NodeConnectorRef destNodeConnector = inventoryReader
                .getNodeConnector(ingress.getValue().firstIdentifierOf(Node.class), destMac);
        if (destNodeConnector != null) {
            flowWriterService.addBidirectionalMacToMacFlows(srcMac, ingress, destMac, destNodeConnector);
        }
    }

    public  ReactiveFlowWriter(InventoryReader inventoryReader, FlowWriterService flowWriterService);

}