Package org.zeromq.ZMQ

Examples of org.zeromq.ZMQ.Socket.recv()

43
44
45
46
47
48
49
50
51
52
53
            receiver.bind("inproc://step2");
            Thread step1 = new Step1 (context);
            step1.start();

            //  Wait for signal
            receiver.recv(0);
            receiver.close ();

            //  Connect to step3 and tell it we're ready
            Socket xmitter = context.socket(ZMQ.PAIR);
            xmitter.connect("inproc://step3");
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
        int workersFired = 0;
        while (true) {
            //  Next message gives us least recently used worker
            String identity = broker.recvStr();
            broker.sendMore(identity);
            broker.recv(0);     //  Envelope delimiter
            broker.recv(0);     //  Response from worker
            broker.sendMore("");

            //  Encourage workers until it's time to fire them
            if (System.currentTimeMillis() < endTime)
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
        while (true) {
            //  Next message gives us least recently used worker
            String identity = broker.recvStr();
            broker.sendMore(identity);
            broker.recv(0);     //  Envelope delimiter
            broker.recv(0);     //  Response from worker
            broker.sendMore("");

            //  Encourage workers until it's time to fire them
            if (System.currentTimeMillis() < endTime)
                broker.send("Work harder");
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
            if (rc == -1)
                break;              //  Interrupted

            //  Handle incoming status messages
            if (items[0].isReadable()) {
                String peer_name = new String(statefe.recv(0));
                String available = new String(statefe.recv(0));
                System.out.printf("%s - %s workers free\n", peer_name, available);
            } else {
                //  Send random values for worker availability
                statebe.send(self, ZMQ.SNDMORE);
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
                break;              //  Interrupted

            //  Handle incoming status messages
            if (items[0].isReadable()) {
                String peer_name = new String(statefe.recv(0));
                String available = new String(statefe.recv(0));
                System.out.printf("%s - %s workers free\n", peer_name, available);
            } else {
                //  Send random values for worker availability
                statebe.send(self, ZMQ.SNDMORE);
                statebe.send(String.format("%d", rand.nextInt(10)), 0);
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
        b.associate(reqSocket);
        c.associate(repSocket);

        byte[] msg = new byte[]{1};
        reqSocket.send(msg, 0);
        byte[] recv = repSocket.recv(0);
        assertEquals(msg, recv);

    }

    @Test
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
        bindAssoc.associate(reqSocket);
        bindAssoc.reverse().associate(repSocket);

        byte[] msg = new byte[]{1};
        reqSocket.send(msg, 0);
        byte[] recv = repSocket.recv(0);
        assertEquals(msg, recv);


    }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
        connectAssoc.reverse().associate(repSocket);
        connectAssoc.associate(reqSocket);

        byte[] msg = new byte[]{1};
        reqSocket.send(msg, 0);
        byte[] recv = repSocket.recv(0);
        assertEquals(msg, recv);

    }

    @Test
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        assoc.associate(pullSocket);

        byte[] msg1 = new byte[]{1};
        byte[] msg2 = new byte[]{2, 2};
        pushSocket1.send(msg1, 0);
        byte[] recv1 = pullSocket.recv(0);
        assertEquals(recv1, msg1);
        pushSocket2.send(msg2, 0);
        byte[] recv2 = pullSocket.recv(0);
        assertEquals(recv2, msg2);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
        byte[] msg2 = new byte[]{2, 2};
        pushSocket1.send(msg1, 0);
        byte[] recv1 = pullSocket.recv(0);
        assertEquals(recv1, msg1);
        pushSocket2.send(msg2, 0);
        byte[] recv2 = pullSocket.recv(0);
        assertEquals(recv2, msg2);


    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.