1 files changed, 0 insertions, 44 deletions

diff --git a/src/org/gnunet/mq/ClientMessageQueue.java b/src/org/gnunet/mq/ClientMessageQueue.java
deleted file mode 100644
index b3fccc7..0000000
--- a/src/org/gnunet/mq/ClientMessageQueue.java
+++ /dev/null
@@ -1,44 +0,0 @@
-package org.gnunet.mq;
-
-
-import org.gnunet.construct.Construct;
-import org.gnunet.util.*;
-
-/**
- * Message queue for org.util.Connection
- */
-public class ClientMessageQueue extends MessageQueue {
-    private final Client client;
-    private final RunaboutMessageReceiver receiver;
-
-    public ClientMessageQueue(Client client, RunaboutMessageReceiver receiver) {
-        this.client = client;
-        this.receiver = receiver;
-    }
-
-    public ClientMessageQueue(Client client) {
-        this(client, null);
-    }
-
-    @Override
-    protected void sendImmediate(final Envelope ev) {
-        int size = Construct.getSize(ev.message);
-        client.notifyTransmitReady(RelativeTime.FOREVER, false, size, new MessageTransmitter() {
-            @Override
-            public void transmit(Connection.MessageSink sink) {
-                sink.send(ev.message);
-                reportMessageSent();
-            }
-
-            @Override
-            public void handleError() {
-                // FIXME
-            }
-        });
-    }
-
-    @Override
-    public void destroy() {
-
-    }
-}