import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow._case.MultipartReplyFlow;
/**
- * pulled out flow stats to notification transformation
+ * Pulled out flow stats to notification transformation.
*/
-public class FlowStatisticsToNotificationTransformer {
+public final class FlowStatisticsToNotificationTransformer {
private FlowStatisticsToNotificationTransformer() {
// Hide implicit constructor
}
/**
+ * Transform to notification.
+ *
* @param mpResult raw multipart response from device
- * @param deviceInfo device state
+ * @param deviceInfo device state
* @param ofVersion device version
- * @param emulatedTxId
- * @param convertorExecutor
+ * @param emulatedTxId emulated transaction Id
+ * @param convertorExecutor convertor executor
* @return notification containing flow stats
*/
public static FlowsStatisticsUpdate transformToNotification(final List<MultipartReply> mpResult,
final ConvertorExecutor convertorExecutor) {
final FlowStatsResponseConvertorData data = new FlowStatsResponseConvertorData(ofVersion.getVersion());
data.setDatapathId(deviceInfo.getDatapathId());
- data.setMatchPath(MatchPath.FLOWSSTATISTICSUPDATE_FLOWANDSTATISTICSMAPLIST_MATCH);
+ data.setMatchPath(MatchPath.FLOWS_STATISTICS_UPDATE_MATCH);
final FlowsStatisticsUpdateBuilder notification = new FlowsStatisticsUpdateBuilder();
final List<FlowAndStatisticsMapList> statsList = new ArrayList<>();
notification.setId(deviceInfo.getNodeId());
convertorExecutor.convert(replyBody.getFlowStats(), data);
- if (outStatsItem.isPresent()) {
- statsList.addAll(outStatsItem.get());
- }
+ outStatsItem.ifPresent(statsList::addAll);
}
return notification.build();