1 files changed, 0 insertions, 41 deletions

diff --git a/src/org/gnunet/mq/MessageQueue.java b/src/org/gnunet/mq/MessageQueue.java
deleted file mode 100644
index de08edf..0000000
--- a/src/org/gnunet/mq/MessageQueue.java
+++ /dev/null
@@ -1,41 +0,0 @@
-package org.gnunet.mq;
-
-
-import org.gnunet.util.GnunetMessage;
-
-import java.util.LinkedList;
-
-/**
- * General-purpose message queue
- */
-public abstract class MessageQueue {
-    private LinkedList<Envelope> queued_envelopes = new LinkedList<>();
-    protected Envelope current_envelope;
-
-    protected abstract void sendImmediate(Envelope ev);
-
-    public void send(GnunetMessage.Body body) {
-        send(new Envelope(body));
-    }
-
-    public void send(Envelope ev) {
-        if (null == current_envelope) {
-            current_envelope = ev;
-            sendImmediate(current_envelope);
-        } else {
-            queued_envelopes.addLast(ev);
-        }
-    }
-
-    protected void reportMessageSent() {
-        if (null == current_envelope)
-            throw new AssertionError();
-        current_envelope.invokeSentNotification();
-        if (queued_envelopes.isEmpty())
-            return;
-        current_envelope = queued_envelopes.pop();
-        sendImmediate(current_envelope);
-    }
-
-    public abstract void destroy();
-}