List of addLocalEntryListener() Examples

Examples of addLocalEntryListener()

com.hazelcast.core.IMap.addLocalEntryListener()
Adds a local entry listener for this map. Added listener will be only listening for the events (add/remove/update/evict) of the locally owned entries.
Note that entries in distributed map are partitioned across the cluster members; each member owns and manages the some portion of the entries. Owned entries are called local entries. This listener will be listening for the events of local entries. Let's say your cluster has member1 and member2. On member2 you added a local listener and from member1, you call map.put(key2, value2). If the key2 is owned by member2 then the local listener will be notified for the add/update event. Also note that entries can migrate to other nodes for load balancing and/or membership change. @param listener entry listener @see #localKeySet()
com.hazelcast.core.MultiMap.addLocalEntryListener()
Adds a local entry listener for this multimap. Added listener will be only listening for the events (add/remove/update) of the locally owned entries.
Note that entries in distributed multimap are partitioned across the cluster members; each member owns and manages the some portion of the entries. Owned entries are called local entries. This listener will be listening for the events of local entries. Let's say your cluster has member1 and member2. On member2 you added a local listener and from member1, you call multimap.put(key2, value2). If the key2 is owned by member2 then the local listener will be notified for the add/update event. Also note that entries can migrate to other nodes for load balancing and/or membership change. @param listener entry listener @see #localKeySet() @return returns registration id.

Examples of com.hazelcast.core.IMap.addLocalEntryListener()

                    @Override
                    public void onEntryEvent(EntryEvent event) {
                        latch.countDown();
                    }
                };
                String id = map.addLocalEntryListener(listener);
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }

View Full Code Here

Examples of com.hazelcast.core.IMap.addLocalEntryListener()

                    @Override
                    public void onEntryEvent(EntryEvent event) {
                        latch.countDown();
                    }
                };
                String id = map.addLocalEntryListener(listener);
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }

View Full Code Here

Examples of com.hazelcast.core.IMap.addLocalEntryListener()

    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener(){
        final IMap map = client.getMap(randomString());
        map.addLocalEntryListener(new DumEntryListener());
    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener_WithPredicate(){
        final IMap map = client.getMap(randomString());

View Full Code Here

Examples of com.hazelcast.core.IMap.addLocalEntryListener()

    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener_WithPredicate(){
        final IMap map = client.getMap(randomString());
        map.addLocalEntryListener(new DumEntryListener(), new DumPredicate(), true);
    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener_WithPredicateAndKey(){
        final IMap map = client.getMap(randomString());

View Full Code Here

Examples of com.hazelcast.core.IMap.addLocalEntryListener()

    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener_WithPredicateAndKey(){
        final IMap map = client.getMap(randomString());
        map.addLocalEntryListener(new DumEntryListener(), new DumPredicate(), "Key", true);
    }


    @Test(expected = UnsupportedOperationException.class)
    public void testLocalKeySet(){
        final IMap map = client.getMap(randomString());

View Full Code Here

Examples of com.hazelcast.core.MultiMap.addLocalEntryListener()

    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener_whenNull() {
        final MultiMap mm = client.getMultiMap(randomString());
        mm.addLocalEntryListener(null);
    }


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener() {
        final MultiMap mm = client.getMultiMap(randomString());

View Full Code Here

Examples of com.hazelcast.core.MultiMap.addLocalEntryListener()


    @Test(expected = UnsupportedOperationException.class)
    public void testAddLocalEntryListener() {
        final MultiMap mm = client.getMultiMap(randomString());
        MyEntryListener myEntryListener = new CountDownValueNotNullListener(1);
        mm.addLocalEntryListener(myEntryListener);
    }


    @Test(expected = IllegalArgumentException.class)
    public void testAddListener_whenListenerNull() throws InterruptedException {
        final MultiMap mm = client.getMultiMap(randomString());

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.