commit | fec9e19036ae25e11f1d895d9a53b955931c13f4 | [log] [tgz] |
---|---|---|
author | Yuta HIGUCHI <y-higuchi@onlab.us> | Sun Sep 28 14:58:02 2014 -0700 |
committer | Yuta HIGUCHI <y-higuchi@onlab.us> | Mon Sep 29 00:29:06 2014 -0700 |
tree | 86c6bbc27bd486c327a87314381dad1220a1c0dd | |
parent | f5712ffbd7d5fbb7a28853d6647bb67a4a672982 [diff] [blame] |
hazelcast event related fixes - suppress locally triggered events - renamed RemoteEventHandler -> RemoteCacheEventHandler - added RemoteCacheEventHandler, which triggers remote event after deserialization Change-Id: Ide3709834ecd7832977575babd6f29727fd003d6
diff --git a/core/store/hz/cluster/src/main/java/org/onlab/onos/store/cluster/impl/DistributedClusterStore.java b/core/store/hz/cluster/src/main/java/org/onlab/onos/store/cluster/impl/DistributedClusterStore.java index 84009ac..0f375f6 100644 --- a/core/store/hz/cluster/src/main/java/org/onlab/onos/store/cluster/impl/DistributedClusterStore.java +++ b/core/store/hz/cluster/src/main/java/org/onlab/onos/store/cluster/impl/DistributedClusterStore.java
@@ -58,7 +58,7 @@ OptionalCacheLoader<NodeId, DefaultControllerNode> nodeLoader = new OptionalCacheLoader<>(storeService, rawNodes); nodes = new AbsentInvalidatingLoadingCache<>(newBuilder().build(nodeLoader)); - rawNodes.addEntryListener(new RemoteEventHandler<>(nodes), true); + rawNodes.addEntryListener(new RemoteCacheEventHandler<>(nodes), true); loadClusterNodes();