diff --git a/lib/slipstream/connection/pipeline.ex b/lib/slipstream/connection/pipeline.ex
index 0dd8870..caa73e4 100644
--- a/lib/slipstream/connection/pipeline.ex
+++ b/lib/slipstream/connection/pipeline.ex
@@ -258,7 +258,8 @@ defmodule Slipstream.Connection.Pipeline do
         topic: cmd.topic,
         event: cmd.event,
         payload: cmd.payload,
-        ref: ref
+        ref: ref,
+        join_ref: state.joins[cmd.topic]
       })
 
     case p do