Class GridCacheQueueAdapter.AddProcessor
- java.lang.Object
-
- org.apache.ignite.internal.processors.datastructures.GridCacheQueueAdapter.AddProcessor
-
- All Implemented Interfaces:
Externalizable,Serializable,javax.cache.processor.EntryProcessor<GridCacheQueueHeaderKey,GridCacheQueueHeader,Long>
- Enclosing class:
- GridCacheQueueAdapter<T>
protected static class GridCacheQueueAdapter.AddProcessor extends Object implements javax.cache.processor.EntryProcessor<GridCacheQueueHeaderKey,GridCacheQueueHeader,Long>, Externalizable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AddProcessor()Required byExternalizable.AddProcessor(IgniteUuid id, int size)
-
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
-
AddProcessor
public AddProcessor()
Required byExternalizable.
-
AddProcessor
public AddProcessor(IgniteUuid id, int size)
- Parameters:
id- Queue unique ID.size- Number of elements to add.
-
-
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
-
-