diff --git a/racketmq/hub/remote-topic.rkt b/racketmq/hub/remote-topic.rkt
index bfa0a3e..900c802 100644
--- a/racketmq/hub/remote-topic.rkt
+++ b/racketmq/hub/remote-topic.rkt
@@ -72,6 +72,8 @@
                                  (hub.topic . ,full-topic)))))
         (established-upstream-hub #f)))
 
+    (on-stop (unsubscribe!))
+
     (begin/dataflow
       (when (not (equal? (current-upstream-hub) (established-upstream-hub)))
         (unsubscribe!)