aboutsummaryrefslogtreecommitdiff
path: root/src/org/gnunet/mq/ClientMessageQueue.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/org/gnunet/mq/ClientMessageQueue.java')
-rw-r--r--src/org/gnunet/mq/ClientMessageQueue.java4
1 files changed, 0 insertions, 4 deletions
diff --git a/src/org/gnunet/mq/ClientMessageQueue.java b/src/org/gnunet/mq/ClientMessageQueue.java
index bfb0466..b3fccc7 100644
--- a/src/org/gnunet/mq/ClientMessageQueue.java
+++ b/src/org/gnunet/mq/ClientMessageQueue.java
@@ -11,18 +11,15 @@ public class ClientMessageQueue extends MessageQueue {
11 private final Client client; 11 private final Client client;
12 private final RunaboutMessageReceiver receiver; 12 private final RunaboutMessageReceiver receiver;
13 13
14
15 public ClientMessageQueue(Client client, RunaboutMessageReceiver receiver) { 14 public ClientMessageQueue(Client client, RunaboutMessageReceiver receiver) {
16 this.client = client; 15 this.client = client;
17 this.receiver = receiver; 16 this.receiver = receiver;
18 } 17 }
19 18
20
21 public ClientMessageQueue(Client client) { 19 public ClientMessageQueue(Client client) {
22 this(client, null); 20 this(client, null);
23 } 21 }
24 22
25
26 @Override 23 @Override
27 protected void sendImmediate(final Envelope ev) { 24 protected void sendImmediate(final Envelope ev) {
28 int size = Construct.getSize(ev.message); 25 int size = Construct.getSize(ev.message);
@@ -40,7 +37,6 @@ public class ClientMessageQueue extends MessageQueue {
40 }); 37 });
41 } 38 }
42 39
43
44 @Override 40 @Override
45 public void destroy() { 41 public void destroy() {
46 42