com.hazelcast.collection.impl.collection

Class AbstractCollectionProxyImpl<S extends RemoteService,E>

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<S>

com.hazelcast.collection.impl.collection.AbstractCollectionProxyImpl<S,E>

All Implemented Interfaces:

DistributedObject, InitializingObject

Direct Known Subclasses:

ListProxyImpl, SetProxyImpl

public abstract class AbstractCollectionProxyImpl<S extends RemoteService,E>
extends AbstractDistributedObject<S>
implements InitializingObject

Field Summary

Fields

Modifier and Type	Field and Description
protected String	name
protected int	partitionId

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCollectionProxyImpl(String name, NodeEngine nodeEngine, S service)

Method Summary

Modifier and Type	Method and Description
boolean	add(E e)
boolean	addAll(Collection<? extends E> c)
String	addItemListener(ItemListener<E> listener, boolean includeValue)
protected void	checkIndexNotNegative(int index)
protected void	checkObjectNotNull(Object o)
void	clear()
boolean	contains(Object o)
boolean	containsAll(Collection<?> c)
protected abstract CollectionConfig	getConfig(NodeEngine nodeEngine)
String	getName() Returns the unique name for this DistributedObject.
int	getPartitionId()
void	initialize()
protected <T> T	invoke(CollectionOperation operation)
boolean	isEmpty()
Iterator<E>	iterator()
boolean	remove(Object o)
boolean	removeAll(Collection<?> c)
boolean	removeItemListener(String registrationId)
boolean	retainAll(Collection<?> c)
int	size()
Object[]	toArray()
<T> T[]	toArray(T[] a)

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, getServiceName, hashCode, invalidate, invokeOnPartition, isClusterVersionEqualTo, isClusterVersionGreaterOrEqual, isClusterVersionGreaterThan, isClusterVersionLessOrEqual, isClusterVersionLessThan, isClusterVersionUnknown, isClusterVersionUnknownOrGreaterOrEqual, isClusterVersionUnknownOrGreaterThan, isClusterVersionUnknownOrLessOrEqual, isClusterVersionUnknownOrLessThan, postDestroy, preDestroy, throwNotActiveException, toData, toString

Methods inherited from class java.lang.Object

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

Field Detail

name

protected final String name

partitionId

protected final int partitionId

Constructor Detail

AbstractCollectionProxyImpl

protected AbstractCollectionProxyImpl(String name,
                                      NodeEngine nodeEngine,
                                      S service)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

getConfig

protected abstract CollectionConfig getConfig(NodeEngine nodeEngine)

getName

public String getName()

Description copied from interface: DistributedObject

Returns the unique name for this DistributedObject. The returned value will never be null. The suggested way for getting name is retrieving it through DistributedObjectUtil.getName(DistributedObject) because this might be also a PrefixedDistributedObject.

Specified by:

getName in interface DistributedObject

Returns:

the unique name for this object.

getPartitionId

public int getPartitionId()

add

public boolean add(E e)

remove

public boolean remove(Object o)

size

public int size()

isEmpty

public boolean isEmpty()

contains

public boolean contains(Object o)

containsAll

public boolean containsAll(Collection<?> c)

addAll

public boolean addAll(Collection<? extends E> c)

retainAll

public boolean retainAll(Collection<?> c)

removeAll

public boolean removeAll(Collection<?> c)

clear

public void clear()

iterator

public Iterator<E> iterator()

toArray

public Object[] toArray()

toArray

public <T> T[] toArray(T[] a)

addItemListener

public String addItemListener(ItemListener<E> listener,
                              boolean includeValue)

removeItemListener

public boolean removeItemListener(String registrationId)

invoke

protected <T> T invoke(CollectionOperation operation)

checkObjectNotNull

protected void checkObjectNotNull(Object o)

checkIndexNotNegative

protected void checkIndexNotNegative(int index)