Drops messages whose TTL is less than zero.
()
| 291 | * Drops messages whose TTL is less than zero. |
| 292 | */ |
| 293 | protected void dropExpiredMessages() { |
| 294 | Message[] messages = getMessageCollection().toArray(new Message[0]); |
| 295 | for (int i=0; i<messages.length; i++) { |
| 296 | int ttl = messages[i].getTtl(); |
| 297 | if (ttl <= 0) { |
| 298 | deleteMessage(messages[i].getId(), true); |
| 299 | } |
| 300 | } |
| 301 | } |
| 302 | |
| 303 | /** |
| 304 | * Tries to make room for a new message. Current implementation simply |
no test coverage detected