Avoid double-wrapping arrival flow description
This commit is contained in:
parent
beddc9d099
commit
830c598aa4
|
@ -253,7 +253,7 @@
|
||||||
(define (insert-flow! b1 topic1 flow topic2 b2)
|
(define (insert-flow! b1 topic1 flow topic2 b2)
|
||||||
(define old-routes (hash-ref (binding-flows b1) flow set))
|
(define old-routes (hash-ref (binding-flows b1) flow set))
|
||||||
(when (set-empty? old-routes)
|
(when (set-empty? old-routes)
|
||||||
(enqueue-message! b1 (arrived (topic (topic-role topic2) flow))))
|
(enqueue-message! b1 (arrived flow)))
|
||||||
(set-binding-flows! b1 (hash-set (binding-flows b1) flow
|
(set-binding-flows! b1 (hash-set (binding-flows b1) flow
|
||||||
(set-add old-routes (route topic1 topic2 b2)))))
|
(set-add old-routes (route topic1 topic2 b2)))))
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue