@Test public void remove() throws InterruptedException { Thread.sleep(10); long now = System.currentTimeMillis(); boolean removed = queue.remove(item100); Assert.assertTrue("item wasn't removed",removed); assertTrue("time removed not within buffer", timeBuffer(now, (long)queue.getLastRemovedTime())); }
@Override public boolean remove(Object o) { boolean r = super.remove(o); lastRemovedTime = System.currentTimeMillis(); return r; }
TrackedPriorityBlockingQueue extends PriorityBlockingQueue<E> implements ITrackedQueue<E> { @Override public boolean remove(Object o) { boolean r = super.remove(o); lastRemovedTime = System.currentTimeMillis(); return r; } }
TrackedPriorityBlockingQueue extends PriorityBlockingQueue<E> implements ITrackedQueue<E> { @Override public boolean remove(Object o) { boolean r = super.remove(o); lastRemovedTime = System.currentTimeMillis(); return r; } TrackedPriorityBlockingQueue(); }
TrackedPriorityBlockingQueue extends PriorityBlockingQueue<E> implements ITrackedQueue<E> { @Override public boolean remove(Object o) { boolean r = super.remove(o); lastRemovedTime = System.currentTimeMillis(); return r; } TrackedPriorityBlockingQueue(); Long getOldestItemTime(); @Override boolean offer(E e); @Override E poll(); @Override boolean remove(Object o); Long getLastAddedTime(); Long getLastRemovedTime(); }
TrackedPriorityBlockingQueue extends PriorityBlockingQueue<E> implements ITrackedQueue<E> { @Override public boolean remove(Object o) { boolean r = super.remove(o); lastRemovedTime = System.currentTimeMillis(); return r; } TrackedPriorityBlockingQueue(); Long getOldestItemTime(); @Override boolean offer(E e); @Override E poll(); @Override boolean remove(Object o); Long getLastAddedTime(); Long getLastRemovedTime();  }