Java 类com.hazelcast.core.MapEvent 实例源码

@Override
public void mapCleared(MapEvent mapEvent) {
    if (mapEvent == null) {
        throw new RuntimeException("Received a null message. Something is wrong");
    }

    for (DestinationDiscoveryCallback callback : callBacks) {
        callback.destinationMapCleared(mapEvent);
    }
}

@Override
public void mapEvicted(MapEvent mapEvent) {
    if (mapEvent == null) {
        throw new RuntimeException("Received a null message. Something is wrong");
    }

    for (DestinationDiscoveryCallback callback : callBacks) {
        callback.destinationMapEvicted(mapEvent);
    }
}

@Override
public void mapCleared(final MapEvent event) {
    m_logger.debug("Member: {} {} - cleared entries: {}",
            event.getMember().getSocketAddress(),
            event.getMember().getUuid(),
            event.getNumberOfEntriesAffected());
}

@Override
public void mapEvicted(final MapEvent event) {
    m_logger.debug("Member: {} {} - evicted entries: {}",
            event.getMember().getSocketAddress(),
            event.getMember().getUuid(),
            event.getNumberOfEntriesAffected());
}

@Override
public void mapCleared(MapEvent event) {
    if (localMember.equals(event.getMember())) {
        // ignore locally triggered event
        return;
    }
    cache.invalidateAll();
}

private void handleMapEvent(MapEvent event) {
    NodeID nodeID = NodeID.getInstance(StringUtils.getBytes(event.getMember().getUuid()));
    // ignore events which were triggered by this node
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        Set<String> sessionJIDs = clusterListener.lookupJIDList(nodeID, cacheName);
        sessionJIDs.clear();
    }
}

private void mapClearedOrEvicted(MapEvent event) {
    NodeID nodeID = NodeID.getInstance(StringUtils.getBytes(event.getMember().getUuid()));
    // ignore events which were triggered by this node
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        nodePresences.get(nodeID).clear();
    }
}

private void mapClearedOrEvicted(MapEvent event) {
    NodeID nodeID = NodeID.getInstance(StringUtils.getBytes(event.getMember().getUuid()));
    // ignore events which were triggered by this node
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        Set<String> sessionJIDs = lookupJIDList(nodeID, componentsCache.getName());
        sessionJIDs.clear();
    }
}

private void handleMapEvent(MapEvent event) {
    NodeID nodeID = NodeID.getInstance(StringUtils.getBytes(event.getMember().getUuid()));
    // ignore events which were triggered by this node
    if (!XMPPServer.getInstance().getNodeID().equals(nodeID)) {
        Set<DomainPair> sessionJIDS = nodeRoutes.get(nodeID);
        if (sessionJIDS != null) {
            sessionJIDS.clear();
        }
    }
}

@Override
public void mapCleared(MapEvent event) {
    // noop
}

@Override
public void mapEvicted(MapEvent event) {
    // noop
}

public void mapEvicted(MapEvent mapEvent) {
    // noop
}

public void mapCleared(MapEvent mapEvent) {
    // noop
}

@Override
public void mapEvicted(MapEvent me) {
}

@Override
public void mapCleared(MapEvent me) {
}

@Override
public void mapEvicted(MapEvent event) {
    listener.mapEvicted(event);
}

@Override
public void mapCleared(MapEvent event) {
    listener.mapCleared(event);
}

@Override
public void mapEvicted(MapEvent event) {
}

@Override
public void mapCleared(MapEvent event) {
}

@Override
public void mapEvicted(MapEvent event) {
}

@Override
public void mapCleared(MapEvent event) {
}

@Override
public void mapEvicted(MapEvent event) {
    System.out.printf("map evicted - Name:%s, Source:%s, Member:%s%n", event.getName(), event.getSource(), event.getMember());
}

@Override public void mapEvicted(final MapEvent event) {
    log.debug("NeighbourMapListener map evict event: {}.", event);
}

@Override public void mapCleared(final MapEvent event) {
    log.debug("NeighbourMapListener map clear event: {}.", event);
}

@Override
public void mapEvicted(MapEvent event) {
    logger.trace("mapEvicted; event: {}", event);
    // make entity inactive ?
}

@Override
public void mapCleared(MapEvent event) {
    logger.trace("mapCleared; event: {}", event);
    // shouldn't be this! delete all roles?
}

@Override
public void mapCleared(MapEvent event) {
    // do nothing
}

@Override
public void mapEvicted(MapEvent event) {
    // do nothing
}

@Override
public void mapEvicted(MapEvent event) {
    logger.trace("mapEvicted; event: {}", event);
}

@Override
public void mapCleared(MapEvent event) {
    logger.trace("mapCleared; event: {}", event);
}

@Override
public void mapEvicted(MapEvent event) {
    // don't think we have to clear everything in this case
}

@Override
public void mapCleared(MapEvent event) {
    cachePath.clear();
    cacheType.clear();
}

@Override
public void mapCleared(MapEvent event) {
    handleMapEvent(event);
}

@Override
public void mapEvicted(MapEvent event) {
    handleMapEvent(event);
}

@Override
public void mapEvicted(MapEvent event) {
    mapClearedOrEvicted(event);
}

@Override
public void mapCleared(MapEvent event) {
    mapClearedOrEvicted(event);
}

@Override
public void mapEvicted(MapEvent event) {
    mapClearedOrEvicted(event);
}

@Override
public void mapCleared(MapEvent event) {
    mapClearedOrEvicted(event);
}

@Override
public void mapCleared(MapEvent event) {
    handleMapEvent(event);
}

@Override
public void mapEvicted(MapEvent event) {
    handleMapEvent(event);
}