commit | 6807c8f141b8e21f9a161a88191b45f70175d55a | [log] [tgz] |
---|---|---|
author | Jordan Halterman <jordan@opennetworking.org> | Mon Aug 28 20:58:24 2017 -0700 |
committer | Ray Milkey <ray@opennetworking.org> | Tue Aug 29 16:52:54 2017 +0000 |
tree | 49a11b7afdda79e60b37c11e00e99df9d3db1c16 | |
parent | 1c2b072d7d0bf077eaba3aeb771c2daf4fa1e93a [diff] [blame] |
Upgrade Atomix to Raft final version Change-Id: I834a3db17bca69855901abb967218135d3547bee
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/RaftMessageContext.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/RaftMessageContext.java index 6123d38..2aecd0b 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/RaftMessageContext.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/RaftMessageContext.java
@@ -36,6 +36,7 @@ final MessageSubject pollSubject; final MessageSubject voteSubject; final MessageSubject appendSubject; + final MessageSubject transferSubject; RaftMessageContext(String prefix) { this.prefix = prefix; @@ -53,6 +54,7 @@ this.pollSubject = getSubject(prefix, "poll"); this.voteSubject = getSubject(prefix, "vote"); this.appendSubject = getSubject(prefix, "append"); + this.transferSubject = getSubject(prefix, "transfer"); } private static MessageSubject getSubject(String prefix, String type) {