| 30 | } |
| 31 | |
| 32 | bool MessageQueue::GetNextMessage() |
| 33 | { |
| 34 | if (NumberOfMessages() > 0 && !AnyRetrievable()) |
| 35 | { |
| 36 | m_lengths.pop_front(); |
| 37 | if (m_messageCounts[0] == 0 && m_messageCounts.size() > 1) |
| 38 | m_messageCounts.pop_front(); |
| 39 | return true; |
| 40 | } |
| 41 | else |
| 42 | return false; |
| 43 | } |
| 44 | |
| 45 | unsigned int MessageQueue::CopyMessagesTo(BufferedTransformation &target, unsigned int count, const std::string &channel) const |
| 46 | { |
no test coverage detected