Renamed PriorityAggregatorQueue to PriorityBlockingAggregatorQueue and moved it to the proper package. Added clear() and clear(int), clearAndPut(int, T) and clearAndOffer(int, T) methods.