}
@Override
- protected LeaderStateChanged newLeaderStateChanged(String memberId, String leaderId) {
+ protected LeaderStateChanged newLeaderStateChanged(String memberId, String leaderId, short leaderPayloadVersion) {
return new ShardLeaderStateChanged(memberId, leaderId,
- isLeader() ? Optional.<DataTree>of(store.getDataTree()) : Optional.<DataTree>absent());
+ isLeader() ? Optional.<DataTree>of(store.getDataTree()) : Optional.<DataTree>absent(),
+ leaderPayloadVersion);
}
private void onDatastoreContext(DatastoreContext context) {