Package com.norconex.crawler.core.cluster

Interface CacheQueue<T>

All Known Implementing Classes:
HazelcastQueueAdapter, InMemoryCacheQueue, MVStoreCacheQueue
public interface CacheQueue<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(T item)
     
    void
    clear()
     
    String
    getName()
    Gets the name of this cache.
    boolean
    isEmpty()
     
    boolean
    isPersistent()
    Returns whether this queue persists data across restarts.
    T
    poll()
     
    List<T>
    pollBatch(int batchSize)
     
    int
    size()
     

  • Method Details

    • add

      void add(T item)

    • poll

      T poll()

    • pollBatch

      List<T> pollBatch(int batchSize)

    • size

      int size()

    • isEmpty

      boolean isEmpty()

    • clear

      void clear()

    • isPersistent

      boolean isPersistent()
      Returns whether this queue persists data across restarts.
      Returns:
      true if the queue is persistent, false if ephemeral

    • getName

      String getName()
      Gets the name of this cache.
      Returns:
      cache name