E
- the type of elements in this setpublic class ClientSetProxy<E> extends ClientProxy implements ISet<E>
ISet
.name
Constructor and Description |
---|
ClientSetProxy(String serviceName,
String name,
ClientContext context) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> c) |
UUID |
addItemListener(ItemListener<E> listener,
boolean includeValue)
Adds an item listener for this collection.
|
void |
clear() |
boolean |
contains(Object o) |
boolean |
containsAll(Collection<?> c) |
protected ClientMessage |
invokeOnPartition(ClientMessage req) |
protected <T> T |
invokeOnPartition(ClientMessage clientMessage,
long invocationTimeoutSeconds) |
protected <T> ClientDelegatingFuture<T> |
invokeOnPartitionAsync(ClientMessage clientMessage,
ClientMessageDecoder clientMessageDecoder) |
protected <T> T |
invokeOnPartitionInterruptibly(ClientMessage clientMessage) |
protected <T> T |
invokeOnPartitionInterruptibly(ClientMessage clientMessage,
long invocationTimeoutSeconds) |
boolean |
isEmpty() |
Iterator<E> |
iterator() |
protected void |
onInitialize()
Called when proxy is created.
|
boolean |
remove(Object o) |
boolean |
removeAll(Collection<?> c) |
boolean |
removeItemListener(UUID registrationId)
Removes the specified item listener.
|
boolean |
retainAll(Collection<?> c) |
int |
size() |
Object[] |
toArray() |
<T> T[] |
toArray(T[] a) |
String |
toString() |
deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getContext, getDistributedObjectName, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onDestroy, onShutdown, postDestroy, preDestroy, registerListener, toData, toObject
clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait
equals, hashCode, spliterator
getName
parallelStream, removeIf, stream
destroy, getPartitionKey, getServiceName
public ClientSetProxy(String serviceName, String name, ClientContext context)
public int size()
public boolean isEmpty()
public Object[] toArray()
public <T> T[] toArray(@Nonnull T[] a)
public boolean containsAll(@Nonnull Collection<?> c)
containsAll
in interface Collection<E>
containsAll
in interface Set<E>
public boolean addAll(@Nonnull Collection<? extends E> c)
public boolean removeAll(@Nonnull Collection<?> c)
public boolean retainAll(@Nonnull Collection<?> c)
public void clear()
@Nonnull public UUID addItemListener(@Nonnull ItemListener<E> listener, boolean includeValue)
ICollection
addItemListener
in interface ICollection<E>
listener
- the item listenerincludeValue
- true
if the updated item should be passed
to the item listener, false
otherwisepublic boolean removeItemListener(@Nonnull UUID registrationId)
ICollection
removeItemListener
in interface ICollection<E>
registrationId
- ID of the listener registrationtrue
if the item listener is removed, false
otherwiseprotected void onInitialize()
ClientProxy
onInitialize
in class ClientProxy
protected ClientMessage invokeOnPartition(ClientMessage req)
protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage) throws InterruptedException
InterruptedException
protected <T> ClientDelegatingFuture<T> invokeOnPartitionAsync(ClientMessage clientMessage, ClientMessageDecoder clientMessageDecoder)
protected <T> T invokeOnPartition(ClientMessage clientMessage, long invocationTimeoutSeconds)
protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage, long invocationTimeoutSeconds) throws InterruptedException
InterruptedException
Copyright © 2019 Hazelcast, Inc.. All rights reserved.