Added Netty based messaging. Updated cluster management to use Netty based messaging
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubject.java b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubject.java
index 97cbf1d..4c9eefa 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubject.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubject.java
@@ -3,24 +3,20 @@
/**
* Representation of a message subject.
*/
-public enum MessageSubject {
+public class MessageSubject {
- /** Represents a first greeting message. */
- HELLO,
+ private final String value;
- /** Signifies announcement about new member. */
- NEW_MEMBER,
+ public MessageSubject(String value) {
+ this.value = value;
+ }
- /** Signifies announcement about leaving member. */
- LEAVING_MEMBER,
+ public String value() {
+ return value;
+ }
- /** Signifies a heart-beat message. */
- ECHO,
-
- /** Anti-Entropy advertisement message. */
- AE_ADVERTISEMENT,
-
- /** Anti-Entropy reply message. */
- AE_REPLY,
-
+ @Override
+ public String toString() {
+ return value;
+ }
}