diff --git a/econtext/core.py b/econtext/core.py
index 2a430439..8a32a7d3 100644
--- a/econtext/core.py
+++ b/econtext/core.py
@@ -823,6 +823,9 @@ class Router(object):
             return self._invoke(msg)
 
         stream = self._stream_by_id.get(msg.dst_id)
+        if stream is None:
+            stream = self._stream_by_id.get(econtext.parent_id)
+
         if stream is None:
             LOG.error('%r: no route for %r, my ID is %r',
                       self, msg, econtext.context_id)