fixed logic with hanging tests in AbstractReceiverWithQueue.stopAfterNotReceivingEventsForSomeTime

This commit is contained in:
Axel Uhl committed 2013-07-09 15:25:18 +02:00
1 parent 71c5282e1c
commit e310e55158
1 file changed
+1
@@ -95,6 +95,7 @@ public abstract class AbstractReceiverWithQueue<A, B, C> implements Runnable, Re
} else {
logger.info("Rescheduling the stopping of receiver "+AbstractReceiverWithQueue.this+
" for another "+timeoutInMilliseconds+"ms");
receivedEventDuringTimeout = false;
TracTracRaceTrackerImpl.scheduler.schedule(this, timeoutInMilliseconds, TimeUnit.MILLISECONDS);
}
}