diff --git a/fetcher.go b/fetcher.go
index 2745a80..c9a8bca 100644
--- a/fetcher.go
+++ b/fetcher.go
@@ -60,7 +60,7 @@ func (f *fetch) Fetch() {
 		for {
 			// f.Close() has been called
 			if f.Closed() {
-				break
+				return
 			}
 			<-f.Ready()
 			f.tryFetchMessage()
@@ -74,7 +74,7 @@ func (f *fetch) Fetch() {
 			close(f.closed)
 			// Signal to Close() that the fetcher has stopped
 			close(f.exit)
-			break
+			return
 		}
 	}
 }
diff --git a/manager.go b/manager.go
index 0e4ee6f..7550546 100644
--- a/manager.go
+++ b/manager.go
@@ -60,7 +60,7 @@ func (m *manager) manage() {
 			m.fetch.Acknowledge(message)
 		case <-m.stop:
 			m.exit <- true
-			break
+			return
 		}
 	}
 }