@Override
protected void doCleanUp() throws Exception {
_reentrantLock.lock();
try {
long currentTime = System.currentTimeMillis();
<BUG>Iterator<NotificationEvent> itr1 =
_getNotificationEvents().iterator();
while (itr1.hasNext()) {</BUG>
NotificationEvent notificationEvent = itr1.next();
<BUG>boolean remove = isRemoveNotificationEvent(
notificationEvent, currentTime);

if (remove) {</BUG>
itr1.remove();

@Override
protected void doCleanUp() throws Exception {
_reentrantLock.lock();
try {
long currentTime = System.currentTimeMillis();
TreeSet<NotificationEvent> notificationEvents =
_getNotificationEvents();
Iterator<NotificationEvent> itr1 = notificationEvents.iterator();
while (itr1.hasNext()) {
NotificationEvent notificationEvent = itr1.next();
if (isRemoveNotificationEvent(
notificationEvent, currentTime)) {
itr1.remove();
