diff --git a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
index 4e1ab4a..e87a0e0 100644
--- a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
+++ b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
@@ -1221,7 +1221,8 @@
                 (objective, error) -> {
                     log.warn("Failed to add {} on {}/{}, vlan {}: {}",
                             mcastIp, deviceId, port.toLong(), assignedVlan, error);
-                    srManager.invalidateNextObj(objective.id());
+                    // Schedule the removal using directly the key
+                    mcastWorker.execute(() -> mcastNextObjStore.remove(mcastStoreKey));
                 });
             ForwardingObjective fwdObj = mcastUtils.fwdObjBuilder(mcastIp, assignedVlan,
                                                           newNextObj.id()).add(context);