Occasional message loss executing a recv right after executing a send on a REQ socket about jzmq HOT 6 CLOSED

Have you been able to reproduce this problem with the latest versions of 0MQ and the Java binding? I would also advise to bring this up on the mailing list, in case you have not done it already.

from jzmq.

Since there have been no comments since September 2010, I will close this issue. Feel free to open a new one if necessary.

from jzmq.

Hello.

I had a sudden detour from my project at the time, sorry for the (enormous) delay. This week I'll try to reproduce the bug with a more recent ZeroMQ version.

from jzmq.

Just to chime in, I couldn't reproduce the bug with the git versions of ZMQ stable and jzmq.

Here's the test code:

Java client:

import org.zeromq.ZMQ;

public class ZQMRepTest {
    public static void main(String[] args) {
        ZMQ.Context ctx = ZMQ.context(1);
        ZMQ.Socket socket = ctx.socket(ZMQ.REQ);

        System.out.println("Connecting...");
        socket.connect("tcp://127.0.0.1:5555");

        System.out.println("Sending...");
        socket.send(new byte[]{3}, 0);

        System.out.println("Receiving...");
        byte[] reply = socket.recv(0);

        System.out.println("Received: " + new String(reply));
    }
}

C server:

int main(int argc, char* argv) {
void* context = zmq_init(1);
void* socket = zmq_socket(context, ZMQ_REP);

zmq_bind(socket, "tcp://127.0.0.1:5555");

while(1) {
    zmq_msg_t request;
    zmq_msg_init(&request);

    zmq_msg_t reply;
    zmq_msg_init_size(&reply, 6);
    memcpy(zmq_msg_data(&reply), "Hello\0", 6);


    if(zmq_recv(socket, &request, ZMQ_NOBLOCK) == 0) {
        zmq_send(socket, &reply, 0);
        printf("Sent reply!\n");

        zmq_msg_close(&request);
        zmq_msg_close(&reply);
    }

    sleep(1);
}

return 0;
}

from jzmq.

OK, maybe this was something that was fixed since the initial report. More the reason to leave the issue closed. Thanks for telling us about your tests.

from jzmq.

Hi every one
I have the same test in Ubuntu 10.11 whith jzmq the problem is i dont receiv anything in subscriber

code :
public static void main(String[] args) {
ZMQ.Context ctx = ZMQ.context(1);
ZMQ.Socket socket = ctx.socket(ZMQ.REQ);

    System.out.println("Connecting...");
    socket.connect("tcp://127.0.0.1:5555");

    System.out.println("Sending...");
    socket.send(new byte[]{3}, 0);

    System.out.println("Receiving...");
    byte[] reply = socket.recv(0);

    System.out.println("Received: " + new String(reply));
}

the result is simply:

Connecting...
Sending...
Receiving..

I'm beginner in zmq so may forget something .

from jzmq.