summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/rmulticast/Message.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Message.java')
-rw-r--r--src/main/java/derms/net/rmulticast/Message.java14
1 files changed, 9 insertions, 5 deletions
diff --git a/src/main/java/derms/net/rmulticast/Message.java b/src/main/java/derms/net/rmulticast/Message.java
index ab2d9ac..180b245 100644
--- a/src/main/java/derms/net/rmulticast/Message.java
+++ b/src/main/java/derms/net/rmulticast/Message.java
@@ -6,14 +6,18 @@ import java.net.InetAddress;
class Message<T extends Serializable & Hashable> implements Serializable {
T payload;
InetAddress sender;
- MessageID[] positiveAcks; // IDs of messages that this message positively acknowledges.
- MessageID[] negativeAcks; // IDs of messages that this message negatively acknowledges.
+ MessageID[] acks; // IDs of messages that this message positively acknowledges.
+ MessageID[] nacks; // IDs of messages that this message negatively acknowledges.
- Message(T payload, InetAddress sender, MessageID[] positiveAcks, MessageID[] negativeAcks) {
+ /**
+ * @param acks IDs of messages that this message positively acknowledges.
+ * @param nacks IDs of messages that this message negatively acknowledges.
+ */
+ Message(T payload, InetAddress sender, MessageID[] acks, MessageID[] nacks) {
this.payload = payload;
this.sender = sender;
- this.positiveAcks = positiveAcks;
- this.negativeAcks = negativeAcks;
+ this.acks = acks;
+ this.nacks = nacks;
}
MessageID id() {