1 files changed, 36 insertions, 0 deletions

diff --git a/src/main/java/org/gnunet/mq/Envelope.java b/src/main/java/org/gnunet/mq/Envelope.java
new file mode 100644
index 0000000..fa19225
--- /dev/null
+++ b/src/main/java/org/gnunet/mq/Envelope.java
@@ -0,0 +1,36 @@
+package org.gnunet.mq;
+
+import org.gnunet.util.Cancelable;
+import org.gnunet.util.GnunetMessage;
+
+/**
+ * Container for a message to be sent by a message queue.
+ */
+public class Envelope implements Cancelable {
+    public final GnunetMessage.Body message;
+    private MessageQueue parent_queue;
+    private NotifySentHandler notify_sent_handler;
+
+    public Envelope(GnunetMessage.Body message) {
+        this.message = message;
+    }
+
+    public void notifySent(NotifySentHandler h) {
+        this.notify_sent_handler = h;
+    }
+
+    public void injectSent() {
+        if (notify_sent_handler != null)
+            notify_sent_handler.onSent();
+    }
+
+    public void cancel() {
+        if (parent_queue == null)
+            throw new AssertionError("can not cancel an unqueued message");
+    }
+
+    /* pkg-private */ void invokeSentNotification() {
+        if (null != notify_sent_handler)
+            notify_sent_handler.onSent();
+    }
+}