syndicate-lang
/
racketmq-2017
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

More logging for remote topics

This commit is contained in:
Tony Garnock-Jones 2016-11-22 10:09:07 +13:00
parent 51088343c4
commit eef6c8c4b7
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
racketmq/hub/remote-topic.rkt
View File

@ -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)))