src/org/gnunet/mq/ClientMessageQueue.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

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() {

    }
}