diff --git a/racketmq/hub/remote-topic.rkt b/racketmq/hub/remote-topic.rkt index 2c10942..9465301 100644 --- a/racketmq/hub/remote-topic.rkt +++ b/racketmq/hub/remote-topic.rkt @@ -36,7 +36,7 @@ (define (remote-topic-main full-topic) (define sub-id (random-hex-string 16)) - (log-info "Remote sub endpoint ~a" sub-id) + (log-info "Remote sub endpoint ~a for topic ~s" sub-id full-topic) (field [current-content-hash #f] [current-content-type #f] @@ -140,6 +140,7 @@ (on-start (poll-upstream!)) ;; always check at least once, for discovery (on-stop (unsubscribe!)) + (on-stop (log-info "Remote topic ~s terminating" full-topic)) (begin/dataflow (when (not (equal? (current-upstream-hub) (established-upstream-hub)))