lichao
2021-04-25 58e3540930d290b315fd24d0414c8feeb7bc8bc1
src/failed_msg.h
@@ -23,6 +23,7 @@
#include "timed_queue.h"
#include <string>
//TODO change storage to map<Remote,list<TimedData<Msg>>>, to avoid retry failed remotes messages.
class FailedMsgQ
{
   typedef std::function<bool(void *)> Func;
@@ -39,7 +40,7 @@
   }
private:
   Func PrepareSender(const std::string &remote, Msg const &msg);
   Func PrepareSender(const std::string &remote, Msg msg);
   TimedFuncQ queue_;
};