Commits on Aug 16, 2016

1. fix erronous errTimedOut ("abandoned subscription...because consuming… …

   … was taking too long")
   
   The expiryTimer continues to run after msg is delivered to
   child.messages. If <-child.feeder takes > MaxProcessingTime (which
   depends on how fast the broker runs), the expiryTimer can expire
   before we Reset() it. If this happens there is a message waiting
   in expiryTimer.C which, if we don't clear it out, makes us think
   the consumer stalled.
   
   This is reproduced with a high traffic partition on a busy
   broker, and measuring the time each line of the loop takes. The
   >100ms stall is the <-child.feeder inside 'range child.feeder'.

   

   nsd20463 committed Aug 16, 2016
   Configuration menu

   • View commit details
   • Copy full SHA for 906ed72
   • Browse repository at this point

   Copy the full SHA

   906ed72 View commit details

   Browse the repository at this point in the history