diff --git a/xfer/multi_publisher.go b/xfer/multi_publisher.go
index 532525600..899551861 100644
--- a/xfer/multi_publisher.go
+++ b/xfer/multi_publisher.go
@@ -123,6 +123,7 @@ func (p *MultiPublisher) Stop() {
 func (p *MultiPublisher) appendFilter(list []tuple, f func(tuple) bool) []tuple {
 	for _, t := range p.list {
 		if !f(t) {
+			t.publisher.Stop()
 			continue
 		}
 		list = append(list, t)