elasticsearch/logstash — pull request #1358 by driskell (2014-05-11 08:53:19+00:00)
Title: Fix broken congestion_interval

Congestion check seems to run for redis for every single even passing through, or for every batch if using batches. I reproduced the issue on my platform and fixed it. Seems it didn't affect me as much as I was using large batches.

This was reported on the mailing list and here is the fix, which I've tested on my platform.