diff --git a/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingManager.java b/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingManager.java
index 9544172..1e322f6 100644
--- a/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingManager.java
+++ b/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingManager.java
@@ -1383,7 +1383,7 @@
                 case CONFIG_UPDATED:
                 case CONFIG_REMOVED:
                     log.trace("Schedule Network Config event {}", event);
-                    mainEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    mainEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 default:
                     break;
@@ -1429,7 +1429,7 @@
                     event.type() == LinkEvent.Type.LINK_UPDATED ||
                     event.type() == LinkEvent.Type.LINK_REMOVED) {
                 log.trace("Schedule Link event {}", event);
-                mainEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                mainEventExecutor.execute(new InternalEventHandler(event));
             }
         }
     }
@@ -1444,7 +1444,7 @@
                 case DEVICE_UPDATED:
                 case DEVICE_AVAILABILITY_CHANGED:
                     log.trace("Schedule Device event {}", event);
-                    mainEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    mainEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 default:
             }
@@ -1457,7 +1457,7 @@
             switch (event.type()) {
                 case TOPOLOGY_CHANGED:
                     log.trace("Schedule Topology event {}", event);
-                    mainEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    mainEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 default:
             }
@@ -1473,7 +1473,7 @@
                 case HOST_REMOVED:
                 case HOST_UPDATED:
                     log.trace("Schedule Host event {}", event);
-                    hostEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    hostEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 default:
                     log.warn("Unsupported host event type: {}", event.type());
@@ -1492,7 +1492,7 @@
                 case SINKS_REMOVED:
                 case ROUTE_REMOVED:
                     log.trace("Schedule Mcast event {}", event);
-                    mcastEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    mcastEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 case ROUTE_ADDED:
                 default:
@@ -1511,7 +1511,7 @@
                 case ROUTE_REMOVED:
                 case ALTERNATIVE_ROUTES_CHANGED:
                     log.trace("Schedule Route event {}", event);
-                    routeEventExecutor.schedule(new InternalEventHandler(event), 100, TimeUnit.MILLISECONDS);
+                    routeEventExecutor.execute(new InternalEventHandler(event));
                     break;
                 default:
                     log.warn("Unsupported route event type: {}", event.type());