Merge pull request #12 from mailgun/thrawn/develop

Now properly respecting the maxBatchLimit when talking with peers
mailgun · Jun 4, 2019 · 15558cd · 15558cd
2 parents 63bb5d8 + 8b30dd6
commit 15558cd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/CHANGELOG b/CHANGELOG
@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.3.2] - 2019-06-03
+### Changes
+* Now properly respecting the maxBatchLimit when talking with peers
+
 ## [0.3.1] - 2019-06-03
 ### Changes
 * Minor log wording change when registering etcd pool

diff --git a/golang/peers.go b/golang/peers.go
@@ -128,7 +128,7 @@ func (c *PeerClient) run() {
 			queue = append(queue, r)
 
 			// Send the queue if we reached our batch limit
-			if len(queue) > c.conf.BatchLimit {
+			if len(queue) == c.conf.BatchLimit {
 				c.sendQueue(queue)
 				queue = nil
 				continue