RPriorityQueue (Redisson 3.16.1 API)

Type Parameters:

V - value type

All Superinterfaces:

Collection<V>, Iterable<V>, Queue<V>, RCollectionAsync<V>, RExpirable, RExpirableAsync, RObject, RObjectAsync, RQueue<V>, RQueueAsync<V>

All Known Subinterfaces:

RPriorityBlockingDeque<V>, RPriorityBlockingQueue<V>, RPriorityDeque<V>

All Known Implementing Classes:

RedissonPriorityBlockingDeque, RedissonPriorityBlockingQueue, RedissonPriorityDeque, RedissonPriorityQueue
```
public interface RPriorityQueue<V>
extends RQueue<V>, RObject
```
Redis based priority deque.

Author:

Nikita Koksharov

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`Comparator<? super V>`	`comparator()`	Returns comparator used by this queue
`V`	`pollLastAndOfferFirstTo(String queueName)`	Retrieves and removes last available tail element of this queue queue and adds it at the head of `queueName`.
`List<V>`	`readAll()`	Returns all queue elements at once
`boolean`	`trySetComparator(Comparator<? super V> comparator)`	Sets new comparator only if current set is empty

Methods inherited from interface java.util.Collection
addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable
forEach

Methods inherited from interface java.util.Queue
add, element, offer, peek, poll, remove

Methods inherited from interface org.redisson.api.RCollectionAsync
addAllAsync, addAsync, containsAllAsync, containsAsync, removeAllAsync, removeAsync, retainAllAsync, sizeAsync

Methods inherited from interface org.redisson.api.RExpirable
clearExpire, expire, expire, expireAt, expireAt, remainTimeToLive

Methods inherited from interface org.redisson.api.RExpirableAsync
clearExpireAsync, expireAsync, expireAsync, expireAtAsync, expireAtAsync, remainTimeToLiveAsync

Methods inherited from interface org.redisson.api.RObject
copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink

Methods inherited from interface org.redisson.api.RObjectAsync
copyAsync, deleteAsync, dumpAsync, getIdleTimeAsync, isExistsAsync, migrateAsync, moveAsync, removeListenerAsync, renameAsync, renamenxAsync, restoreAndReplaceAsync, restoreAndReplaceAsync, restoreAsync, restoreAsync, sizeInMemoryAsync, touchAsync, unlinkAsync

Methods inherited from interface org.redisson.api.RQueue
addListener, poll

Methods inherited from interface org.redisson.api.RQueueAsync
addListenerAsync, offerAsync, peekAsync, pollAsync, pollAsync, pollLastAndOfferFirstToAsync, readAllAsync

- Method Detail
  - comparator
```
Comparator<? super V> comparator()
```
    Returns comparator used by this queue
    
    Returns:
    
    comparator object
  - readAll
```
List<V> readAll()
```
    Returns all queue elements at once
    
    Specified by:
    
    readAll in interface RQueue<V>
    
    Returns:
    
    elements
  - pollLastAndOfferFirstTo
```
V pollLastAndOfferFirstTo(String queueName)
```
    Retrieves and removes last available tail element of this queue queue and adds it at the head of queueName.
    
    Specified by:
    
    pollLastAndOfferFirstTo in interface RQueue<V>
    
    Parameters:
    
    queueName - - names of destination queue
    
    Returns:
    
    the tail of this queue, or null if the specified waiting time elapses before an element is available
  - trySetComparator
```
boolean trySetComparator(Comparator<? super V> comparator)
```
    Sets new comparator only if current set is empty
    
    Parameters:
    
    comparator - for values
    
    Returns:
    
    true if new comparator setted false otherwise