limit message queue to 2000

This commit is contained in:
badaix 2016-11-17 11:48:21 +01:00
parent 2d1fdf3422
commit b17368d77e

View file

@ -131,7 +131,7 @@ void StreamSession::sendAsync(const shared_ptr<const msg::BaseMessage>& message,
return; return;
//the writer will take care about old messages //the writer will take care about old messages
while (messages_.size() > 10000)// chunk->getDuration() > 10000) while (messages_.size() > 2000)// chunk->getDuration() > 10000)
messages_.pop(); messages_.pop();
if (sendNow) if (sendNow)