Upgrade Atomix to Raft final version
Change-Id: I834a3db17bca69855901abb967218135d3547bee
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueService.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueService.java
index 08a894b..b1d6698 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueService.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueService.java
@@ -90,7 +90,7 @@
public void install(SnapshotReader reader) {
registeredWorkers = Maps.newHashMap();
for (Long sessionId : reader.<Set<Long>>readObject(SERIALIZER::decode)) {
- registeredWorkers.put(sessionId, getSessions().getSession(sessionId));
+ registeredWorkers.put(sessionId, sessions().getSession(sessionId));
}
assignments = reader.readObject(SERIALIZER::decode);
unassignedTasks = reader.readObject(SERIALIZER::decode);
@@ -168,7 +168,7 @@
})
.collect(Collectors.toCollection(ArrayList::new));
} catch (Exception e) {
- getLogger().warn("State machine update failed", e);
+ logger().warn("State machine update failed", e);
throw Throwables.propagate(e);
}
}
@@ -185,7 +185,7 @@
}
});
} catch (Exception e) {
- getLogger().warn("State machine update failed", e);
+ logger().warn("State machine update failed", e);
throw Throwables.propagate(e);
}
}