@Test public void testSetItemListenerWithoutValue() { final CountDownLatch latch = new CountDownLatch(2); ISet<String> set = getHazelcastClient().getSet("testSetItemListenerWithoutValue"); set.addItemListener(new ItemListener<String>() { public void itemAdded(ItemEvent<String> itemEvent) { assertNull(itemEvent.getItem()); latch.countDown(); } public void itemRemoved(ItemEvent<String> itemEvent) { assertNull(itemEvent.getItem()); latch.countDown(); } }, false); set.add("hello"); set.remove("hello"); try { assertTrue(latch.await(5, TimeUnit.SECONDS)); } catch (InterruptedException ignored) { } }
public <E> ISet<E> getSet(String name) { return (ISet<E>) getClientProxy(Prefix.SET + name); }
HazelcastClient implements HazelcastInstance { public <E> ISet<E> getSet(String name) { return (ISet<E>) getClientProxy(Prefix.SET + name); } }
HazelcastClient implements HazelcastInstance { public <E> ISet<E> getSet(String name) { return (ISet<E>) getClientProxy(Prefix.SET + name); } private  HazelcastClient(ClientConfig config); }
HazelcastClient implements HazelcastInstance { public <E> ISet<E> getSet(String name) { return (ISet<E>) getClientProxy(Prefix.SET + name); } private  HazelcastClient(ClientConfig config); InRunnable getInRunnable(); OutRunnable getOutRunnable(); static HazelcastClient newHazelcastClient(ClientConfig config); Config getConfig(); PartitionService getPartitionService(); ClientService getClientService(); LoggingService getLoggingService(); IMap<K, V> getMap(String name); Object getClientProxy(Object o); com.hazelcast.core.Transaction getTransaction(); ConnectionManager getConnectionManager(); void addInstanceListener(InstanceListener instanceListener); Cluster getCluster(); ExecutorService getExecutorService(); ExecutorService getExecutorService(String name); IdGenerator getIdGenerator(String name); AtomicNumber getAtomicNumber(String name); ICountDownLatch getCountDownLatch(String name); ISemaphore getSemaphore(String name); Collection<Instance> getInstances(); IList<E> getList(String name); ILock getLock(Object obj); MultiMap<K, V> getMultiMap(String name); String getName(); IQueue<E> getQueue(String name); ISet<E> getSet(String name); ITopic<E> getTopic(String name); void removeInstanceListener(InstanceListener instanceListener); static void shutdownAll(); static Collection<HazelcastClient> getAllHazelcastClients(); void shutdown(); boolean isActive(); void restart(); LifecycleService getLifecycleService(); ClientConfig getClientConfig(); }
HazelcastClient implements HazelcastInstance { public <E> ISet<E> getSet(String name) { return (ISet<E>) getClientProxy(Prefix.SET + name); } private  HazelcastClient(ClientConfig config); InRunnable getInRunnable(); OutRunnable getOutRunnable(); static HazelcastClient newHazelcastClient(ClientConfig config); Config getConfig(); PartitionService getPartitionService(); ClientService getClientService(); LoggingService getLoggingService(); IMap<K, V> getMap(String name); Object getClientProxy(Object o); com.hazelcast.core.Transaction getTransaction(); ConnectionManager getConnectionManager(); void addInstanceListener(InstanceListener instanceListener); Cluster getCluster(); ExecutorService getExecutorService(); ExecutorService getExecutorService(String name); IdGenerator getIdGenerator(String name); AtomicNumber getAtomicNumber(String name); ICountDownLatch getCountDownLatch(String name); ISemaphore getSemaphore(String name); Collection<Instance> getInstances(); IList<E> getList(String name); ILock getLock(Object obj); MultiMap<K, V> getMultiMap(String name); String getName(); IQueue<E> getQueue(String name); ISet<E> getSet(String name); ITopic<E> getTopic(String name); void removeInstanceListener(InstanceListener instanceListener); static void shutdownAll(); static Collection<HazelcastClient> getAllHazelcastClients(); void shutdown(); boolean isActive(); void restart(); LifecycleService getLifecycleService(); ClientConfig getClientConfig();  }