diff --git a/sender_worker.go b/sender_worker.go
index 589a457..c898e95 100644
--- a/sender_worker.go
+++ b/sender_worker.go
@@ -115,6 +115,7 @@ func NotifyViaHTTP(events <-chan GenericMessage, wg *sync.WaitGroup, logger *log
 				}
 			}
 		}
+		close(returnEvents)
 	}()
 
 	return returnEvents