Class GridCacheQueueAdapter.PollProcessor
- java.lang.Object
-
- org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter.PollProcessor
-
- All Implemented Interfaces:
Externalizable,Serializable,javax.cache.processor.EntryProcessor<GridCacheQueueHeaderKey,GridCacheQueueHeader,Long>
- Enclosing class:
- GridCacheQueueAdapter<T>
protected static class GridCacheQueueAdapter.PollProcessor extends Object implements javax.cache.processor.EntryProcessor<GridCacheQueueHeaderKey,GridCacheQueueHeader,Long>, Externalizable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description PollProcessor()Required byExternalizable.PollProcessor(IgniteUuid id)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Longprocess(javax.cache.processor.MutableEntry<GridCacheQueueHeaderKey,GridCacheQueueHeader> e, Object... args)voidreadExternal(ObjectInput in)voidwriteExternal(ObjectOutput out)
-
-
-
Constructor Detail
-
PollProcessor
public PollProcessor()
Required byExternalizable.
-
PollProcessor
public PollProcessor(IgniteUuid id)
- Parameters:
id- Queue unique ID.
-
-
Method Detail
-
process
public Long process(javax.cache.processor.MutableEntry<GridCacheQueueHeaderKey,GridCacheQueueHeader> e, Object... args)
- Specified by:
processin interfacejavax.cache.processor.EntryProcessor<GridCacheQueueHeaderKey,GridCacheQueueHeader,Long>
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Throws:
IOExceptionClassNotFoundException
-
-