import com.tangosol.util.MapEvent; //导入依赖的package包/类
@Override
public void onMapEvent(MapEvent event) {

          LOG.trace("got event: {}, type: {}", event, event.getClass().getName());
          LOG.trace("got entry: {} and source: {}", event.getOldEntry(), event.getSource());
	
       if (event instanceof CacheEvent && ((CacheEvent) event).isSynthetic()) {
           //LOG.trace("Skipping synthetic event: {}", event);
           return;
       }

       //if (!context.isKeyOwned(evt.getKey())) {
       //    LOGGER.trace("Skipping redistribution event: {}", evt);
       //    return;
       //}
	
	trigger.process(new SimpleMapEntry(event.getKey(), event.getNewValue(), event.getOldValue()));
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
private void simuateCacheInserts(Cache<Object, Object> cache) {
    MapListener mapListener = mapListeners.get(cache);
    if (mapListener != null) {
        if (cache instanceof CacheWrapper) {
            Cache wrapped = ((CacheWrapper) cache).getWrappedCache();
            if (wrapped instanceof ClusteredCache) {
                ClusteredCache clusteredCache = (ClusteredCache) wrapped;
                for (Map.Entry entry : cache.entrySet()) {
                    MapEvent event = new MapEvent(clusteredCache.map, MapEvent.ENTRY_INSERTED, entry.getKey(), null,
                            entry.getValue());
                    mapListener.entryInserted(event);
                }
            }
        }
    }
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryInserted(MapEvent mapEvent) {
    byte[] nodeID = getNodeID(mapEvent, false);
    // Ignore events origintated from this JVM
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        // Check if the directed presence was sent to an entity hosted by this JVM
        RoutingTable routingTable = XMPPServer.getInstance().getRoutingTable();
        String sender = mapEvent.getKey().toString();
        Collection<String> handlers = new HashSet<String>();
        for (JID handler : getHandlers(mapEvent)) {
            if (routingTable.isLocalRoute(handler)) {
                // Keep track of the remote sender and local handler that got the directed presence
                handlers.addAll(getReceivers(mapEvent, handler));
            }
        }
        if (!handlers.isEmpty()) {
            Map<String, Collection<String>> senders = nodePresences.get(NodeID.getInstance(nodeID));
            if (senders == null) {
                senders = new ConcurrentHashMap<String, Collection<String>>();
                nodePresences.put(NodeID.getInstance(nodeID), senders);
            }
            senders.put(sender, handlers);
        }
    }
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
void handleMapEvent(MapEvent mapEvent, boolean removal) {
    NodeID nodeID = getNodeID(mapEvent, removal);
    //ignore items which this node has added
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        Set<String> sessionJIDS = clusterListener.lookupJIDList(nodeID, cacheName);
        if (removal) {
            sessionJIDS.remove(mapEvent.getKey().toString());
        }
        else {
            sessionJIDS.add(mapEvent.getKey().toString());
        }
    }
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryUpdated(MapEvent mapEvent) {
    byte[] nodeID = getNodeID(mapEvent, false);
    // Ignore events origintated from this JVM
    if (nodeID != null && !XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        // Check if the directed presence was sent to an entity hosted by this JVM
        RoutingTable routingTable = XMPPServer.getInstance().getRoutingTable();
        String sender = mapEvent.getKey().toString();
        Collection<String> handlers = new HashSet<String>();
        for (JID handler : getHandlers(mapEvent)) {
            if (routingTable.isLocalRoute(handler)) {
                // Keep track of the remote sender and local handler that got the directed presence
                handlers.addAll(getReceivers(mapEvent, handler));
            }
        }
        Map<String, Collection<String>> senders = nodePresences.get(NodeID.getInstance(nodeID));
        if (senders == null) {
            senders = new ConcurrentHashMap<String, Collection<String>>();
            nodePresences.put(NodeID.getInstance(nodeID), senders);
        }
        if (!handlers.isEmpty()) {
            senders.put(sender, handlers);
        }
        else {
            // Remove any traces of the sender since no directed presence was sent to this JVM
            senders.remove(sender);
        }
    }
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryDeleted(MapEvent mapEvent) {
    if (mapEvent.getNewValue() == null && ((Collection)mapEvent.getOldValue()).isEmpty()) {
        // Nothing to remove
        return;
    }
    byte[] nodeID = getNodeID(mapEvent, true);
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        String sender = mapEvent.getKey().toString();
        nodePresences.get(NodeID.getInstance(nodeID)).remove(sender);
    }
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
byte[] getNodeID(MapEvent mapEvent, boolean removal) {
    Object value = removal ? mapEvent.getOldValue() : mapEvent.getNewValue();
    Collection<DirectedPresence> directedPresences = (Collection<DirectedPresence>) value;
    if (directedPresences.isEmpty()) {
        Log.warn("ClusteringListener - Found empty directed presences for sender: " + mapEvent.getKey());
        return null;
    }
    return directedPresences.iterator().next().getNodeID();
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
Collection<JID> getHandlers(MapEvent mapEvent) {
    Object value = mapEvent.getNewValue();
    Collection<JID> answer = new ArrayList<JID>();
    for (DirectedPresence directedPresence : (Collection<DirectedPresence>)value) {
        answer.add(directedPresence.getHandler());
    }
    return answer;
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
Set<String> getReceivers(MapEvent mapEvent, JID handler) {
    Object value = mapEvent.getNewValue();
    for (DirectedPresence directedPresence : (Collection<DirectedPresence>)value) {
        if (directedPresence.getHandler().equals(handler)) {
            return directedPresence.getReceivers();
        }
    }
    return Collections.emptySet();
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
@Override
protected void onMapEvent(MapEvent mapEvent) {
    latch.countDown();
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryInserted(MapEvent mapEvent) {
    handleMapEvent(mapEvent, false);
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryUpdated(MapEvent mapEvent) {
    handleMapEvent(mapEvent, false);
}
 

import com.tangosol.util.MapEvent; //导入依赖的package包/类
public void entryDeleted(MapEvent mapEvent) {
    handleMapEvent(mapEvent, true);
}