Package org.redisson

Class RedissonDelayedQueue<V>

    • Method Detail

      • offer

        public void offer​(V e,
                          long delay,
                          TimeUnit timeUnit)
        Description copied from interface: RDelayedQueue
        Inserts element into this queue with specified transfer delay to destination queue.
        Specified by:
        offer in interface RDelayedQueue<V>
        Parameters:
        e - the element to add
        delay - for transition
        timeUnit - for delay
      • offerAsync

        public RFuture<Void> offerAsync​(V e,
                                        long delay,
                                        TimeUnit timeUnit)
        Description copied from interface: RDelayedQueue
        Inserts element into this queue with specified transfer delay to destination queue.
        Specified by:
        offerAsync in interface RDelayedQueue<V>
        Parameters:
        e - the element to add
        delay - for transition
        timeUnit - for delay
        Returns:
        void
      • add

        public boolean add​(V e)
        Specified by:
        add in interface Collection<V>
        Specified by:
        add in interface Queue<V>
      • offer

        public boolean offer​(V e)
        Specified by:
        offer in interface Queue<V>
      • remove

        public V remove()
        Specified by:
        remove in interface Queue<V>
      • poll

        public V poll()
        Specified by:
        poll in interface Queue<V>
      • element

        public V element()
        Specified by:
        element in interface Queue<V>
      • peek

        public V peek()
        Specified by:
        peek in interface Queue<V>
      • toArray

        public <T> T[] toArray​(T[] a)
        Specified by:
        toArray in interface Collection<V>
      • readAll

        public List<V> readAll()
        Description copied from interface: RQueue
        Returns all queue elements at once
        Specified by:
        readAll in interface RQueue<V>
        Returns:
        elements
      • poll

        public List<V> poll​(int limit)
        Description copied from interface: RQueue
        Retrieves and removes the head elements of this queue. Elements amount limited by limit param.
        Specified by:
        poll in interface RQueue<V>
        Returns:
        list of head elements
      • pollAsync

        public RFuture<List<V>> pollAsync​(int limit)
        Description copied from interface: RQueueAsync
        Retrieves and removes the head elements of this queue. Elements amount limited by limit param.
        Specified by:
        pollAsync in interface RQueueAsync<V>
        Returns:
        list of head elements
      • removeAsync

        public RFuture<Boolean> removeAsync​(Object o)
        Description copied from interface: RCollectionAsync
        Removes a single instance of the specified element from this collection, if it is present.
        Specified by:
        removeAsync in interface RCollectionAsync<V>
        Parameters:
        o - element to be removed from this collection, if present
        Returns:
        true if an element was removed as a result of this call
      • containsAllAsync

        public RFuture<Boolean> containsAllAsync​(Collection<?> c)
        Description copied from interface: RCollectionAsync
        Returns true if this collection contains all of the elements in the specified collection.
        Specified by:
        containsAllAsync in interface RCollectionAsync<V>
        Parameters:
        c - collection to be checked for containment in this collection
        Returns:
        true if this collection contains all of the elements in the specified collection
      • removeAllAsync

        public RFuture<Boolean> removeAllAsync​(Collection<?> c)
        Description copied from interface: RCollectionAsync
        Removes all of this collection's elements that are also contained in the specified collection.
        Specified by:
        removeAllAsync in interface RCollectionAsync<V>
        Parameters:
        c - collection containing elements to be removed from this collection
        Returns:
        true if this collection changed as a result of the call
      • retainAllAsync

        public RFuture<Boolean> retainAllAsync​(Collection<?> c)
        Description copied from interface: RCollectionAsync
        Retains only the elements in this collection that are contained in the specified collection.
        Specified by:
        retainAllAsync in interface RCollectionAsync<V>
        Parameters:
        c - collection containing elements to be retained in this collection
        Returns:
        true if this collection changed as a result of the call
      • expireAsync

        public RFuture<Boolean> expireAsync​(long timeToLive,
                                            TimeUnit timeUnit)
        Description copied from interface: RExpirableAsync
        Set a timeout for object in async mode. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • clearExpireAsync

        public RFuture<Boolean> clearExpireAsync()
        Description copied from interface: RExpirableAsync
        Clear an expire timeout or expire date for object in async mode. Object will not be deleted.
        Specified by:
        clearExpireAsync in interface RExpirableAsync
        Returns:
        true if the timeout was cleared and false if not
      • peekAsync

        public RFuture<V> peekAsync()
        Description copied from interface: RQueueAsync
        Retrieves the head of this queue in async mode.
        Specified by:
        peekAsync in interface RQueueAsync<V>
        Returns:
        the head of this queue, or null
      • pollAsync

        public RFuture<V> pollAsync()
        Description copied from interface: RQueueAsync
        Retrieves and removes the head of this queue in async mode.
        Specified by:
        pollAsync in interface RQueueAsync<V>
        Returns:
        the head of this queue, or null
      • offerAsync

        public RFuture<Boolean> offerAsync​(V e)
        Description copied from interface: RQueueAsync
        Inserts the specified element into this queue.
        Specified by:
        offerAsync in interface RQueueAsync<V>
        Parameters:
        e - the element to add
        Returns:
        true if successful, or false
      • pollLastAndOfferFirstToAsync

        public RFuture<V> pollLastAndOfferFirstToAsync​(String queueName)
        Description copied from interface: RQueueAsync
        Retrieves and removes last available tail element of this queue queue and adds it at the head of queueName.
        Specified by:
        pollLastAndOfferFirstToAsync in interface RQueueAsync<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
      • containsAsync

        public RFuture<Boolean> containsAsync​(Object o)
        Description copied from interface: RCollectionAsync
        Returns true if this collection contains encoded state of the specified element.
        Specified by:
        containsAsync in interface RCollectionAsync<V>
        Parameters:
        o - element whose presence in this collection is to be tested
        Returns:
        true if this collection contains the specified element and false otherwise
      • addAsync

        public RFuture<Boolean> addAsync​(V e)
        Description copied from interface: RCollectionAsync
        Adds element into this collection.
        Specified by:
        addAsync in interface RCollectionAsync<V>
        Parameters:
        e - - element to add
        Returns:
        true if an element was added and false if it is already present
      • addAllAsync

        public RFuture<Boolean> addAllAsync​(Collection<? extends V> c)
        Description copied from interface: RCollectionAsync
        Adds all elements contained in the specified collection
        Specified by:
        addAllAsync in interface RCollectionAsync<V>
        Parameters:
        c - - collection of elements to add
        Returns:
        true if at least one element was added and false if all elements are already present
      • pollLastAndOfferFirstTo

        public V pollLastAndOfferFirstTo​(String dequeName)
        Description copied from interface: RQueue
        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:
        dequeName - - names of destination queue
        Returns:
        the tail of this queue, or null if the specified waiting time elapses before an element is available
      • destroy

        public void destroy()
        Description copied from interface: RDestroyable
        Destroys object when it's not necessary anymore.
        Specified by:
        destroy in interface RDestroyable
      • expire

        public boolean expire​(long timeToLive,
                              TimeUnit timeUnit)
        Description copied from interface: RExpirable
        Set a timeout for object. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • expireAt

        public boolean expireAt​(long timestamp)
        Description copied from interface: RExpirable
        Specified by:
        expireAt in interface RExpirable
        Parameters:
        timestamp - - expire date in milliseconds (Unix timestamp)
        Returns:
        true if the timeout was set and false if not
      • expire

        public boolean expire​(Instant instant)
        Description copied from interface: RExpirable
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        instant - - expire date
        Returns:
        true if the timeout was set and false if not
      • expireAsync

        public RFuture<Boolean> expireAsync​(Instant instant)
        Description copied from interface: RExpirableAsync
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        instant - - expire date
        Returns:
        true if the timeout was set and false if not
      • clearExpire

        public boolean clearExpire()
        Description copied from interface: RExpirable
        Clear an expire timeout or expire date for object.
        Specified by:
        clearExpire in interface RExpirable
        Returns:
        true if timeout was removed false if object does not exist or does not have an associated timeout
      • remainTimeToLive

        public long remainTimeToLive()
        Description copied from interface: RExpirable
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLive in interface RExpirable
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
      • remainTimeToLiveAsync

        public RFuture<Long> remainTimeToLiveAsync()
        Description copied from interface: RExpirableAsync
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLiveAsync in interface RExpirableAsync
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.