diff --git a/zk_coordinator.go b/zk_coordinator.go
index <HASH>..<HASH> 100644
--- a/zk_coordinator.go
+++ b/zk_coordinator.go
@@ -673,6 +673,8 @@ func (this *ZookeeperCoordinator) waitForMembersToJoin(barrierPath string, expec
 			}
 			// Haven't seen all expected consumers on this barrier path.  Watch for changes to the path...
 			select {
+			case <-stopChan:
+				return
 			case <-zkMemberJoinedWatcher:
 				continue
 			}
Added case for stopChan on inner select to break out.