diff --git a/src/main/java/org/opencord/igmpproxy/IgmpManager.java b/src/main/java/org/opencord/igmpproxy/IgmpManager.java
index 1b95105..1b4285b 100644
--- a/src/main/java/org/opencord/igmpproxy/IgmpManager.java
+++ b/src/main/java/org/opencord/igmpproxy/IgmpManager.java
@@ -196,7 +196,7 @@
                 }
         );
 
-        oltData.keySet().forEach(d->provisionDefaultFlows(d));
+        oltData.keySet().forEach(d -> provisionDefaultFlows(d));
         if (connectPointMode) {
             provisionConnectPointFlows();
         } else {
@@ -781,7 +781,7 @@
             return;
         }
 
-        oltData.keySet().forEach(deviceId ->provisionUplinkFlows(deviceId));
+        oltData.keySet().forEach(deviceId -> provisionUplinkFlows(deviceId));
     }
     private void unprovisionUplinkFlows() {
         oltData.keySet().forEach(deviceId ->