Package org.apache.ignite.internal.processors.datastructures

Class GridAtomicCacheQueueImpl<T>

java.lang.Object

java.util.AbstractCollection<T>

org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter<T>

org.apache.ignite.internal.processors.datastructures.GridAtomicCacheQueueImpl<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>, IgniteQueue<T>

public class GridAtomicCacheQueueImpl<T>
extends GridCacheQueueAdapter<T>

IgniteQueue implementation using atomic cache.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter

GridCacheQueueAdapter.AddProcessor, GridCacheQueueAdapter.ClearProcessor, GridCacheQueueAdapter.PollProcessor, GridCacheQueueAdapter.RemoveProcessor

Field Summary

Fields

Modifier and Type	Field	Description
static int	DFLT_ATOMIC_CACHE_QUERY_RETRY_TIMEOUT

Fields inherited from class org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter

cache, cctx, id, log, QUEUE_REMOVED_IDX, queueKey, queueName

Constructor Summary

Constructors

Constructor	Description
GridAtomicCacheQueueImpl(String queueName, GridCacheQueueHeader hdr, GridCacheContext<?,?> cctx)

Method Summary

Modifier and Type	Method	Description
boolean	addAll(Collection<? extends T> items)
boolean	offer(T item)
T	poll()
protected void	removeItem(long rmvIdx)	Removes item with given index from queue.

Methods inherited from class org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter

add, affinityCall, affinityRun, bounded, capacity, checkRemoved, checkRemoved, clear, clear, close, collocated, drainTo, drainTo, element, equals, hashCode, id, itemKey, iterator, name, offer, onClientDisconnected, onHeaderChanged, onKernalStop, onRemoved, peek, poll, put, remainingCapacity, remove, removed, size, take, toString, withKeepBinary

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, removeIf, spliterator, stream, toArray

Methods inherited from interface org.apache.ignite.IgniteQueue

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

DFLT_ATOMIC_CACHE_QUERY_RETRY_TIMEOUT

public static final int DFLT_ATOMIC_CACHE_QUERY_RETRY_TIMEOUT

See Also:

IgniteSystemProperties.IGNITE_ATOMIC_CACHE_QUEUE_RETRY_TIMEOUT, Constant Field Values

Constructor Detail

GridAtomicCacheQueueImpl

public GridAtomicCacheQueueImpl(String queueName,
                                GridCacheQueueHeader hdr,
                                GridCacheContext<?,?> cctx)

Parameters:

queueName - Queue name.

hdr - Queue header.

cctx - Cache context.

Method Detail

offer

public boolean offer(T item)
              throws IgniteException

Throws:

IgniteException

poll

@Nullable
public T poll()
       throws IgniteException

Throws:

IgniteException

addAll

public boolean addAll(Collection<? extends T> items)

Specified by:

addAll in interface Collection<T>

Specified by:

addAll in interface IgniteQueue<T>

Overrides:

addAll in class AbstractCollection<T>

removeItem

protected void removeItem(long rmvIdx)
                   throws IgniteCheckedException

Removes item with given index from queue.

Specified by:

removeItem in class GridCacheQueueAdapter<T>

Parameters:

rmvIdx - Index of item to be removed.

Throws:

IgniteCheckedException - If failed.