diff --git a/include/amqpcpp/libev.h b/include/amqpcpp/libev.h index e2dfa2e..76eea2f 100644 --- a/include/amqpcpp/libev.h +++ b/include/amqpcpp/libev.h @@ -267,12 +267,12 @@ private: // sent only after _timout/2 seconds again _from now_ (no catching up) _next = now + std::max(_timeout / 2, 1); } - + // reset the timer to trigger again later ev_timer_set(&_timer, std::min(_next, _expire) - now, 0.0); - - // restart the timer - ev_timer_again(_loop, &_timer); + + // and start it again + ev_timer_start(_loop, &_timer); // and because the timer is running again, we restore the refcounter ev_unref(_loop); @@ -368,9 +368,6 @@ private: // find the earliest thing that expires ev_timer_set(&_timer, std::min(_next, _expire) - now, 0.0); - // restart the timer - ev_timer_again(_loop, &_timer); - // expose the accepted interval return _timeout; }