diff --git a/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java b/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
index 4ae2825..9271976 100644
--- a/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
+++ b/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
@@ -131,6 +131,9 @@
           public void forward(DeviceId deviceId, ForwardingObjective forwardingObjective) {
               synchronized (forwardMap) {
                 forwardMap.put(deviceId, forwardingObjective);
+                forwardingObjective.context().ifPresent(context -> {
+                    context.onSuccess(forwardingObjective);
+                });
                 forwardMap.notify();
               }
           }