Package org.zeromq.ZMQ

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

84
85
86
87
88
89
90
91
92
93
94
        final String addr = receiverUrl.toString().replaceFirst(
            "zmq:/?/?", "");
        final Socket socket = ZMQ.getSocket(org.zeromq.ZMQ.PUSH);
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl, org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message, 0);
         
        } catch (final Exception e) {
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
            "zmq:/?/?", "");
        final Socket socket = ZMQ.getSocket(org.zeromq.ZMQ.PUSH);
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl, org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message, 0);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        final Socket socket = ZMQ.getSocket(org.zeromq.ZMQ.PUSH);
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl, org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message, 0);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
        }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl, org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message, 0);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
        }
        socket.setTCPKeepAlive(-1);
View Full Code Here
827
828
829
830
831
832
833
834
835
836
837
       
        assertTrue(socket.monitor("inproc://monitor.socket", ZMQ.EVENT_DISCONNECTED));
        monitor.connect("inproc://monitor.socket");

        byte[] req ="request".getBytes();
        helper.send(req, 100);
        assertArrayEquals(socket.recv(100), req);

        helper.close();
        event = Event.recv(monitor);
        assertNotNull("No event was received", event);
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
        };

        Socket pipe = ZThread.fork(ctx, attached);
        assert (pipe != null);

        pipe.send("ping");
        String pong = pipe.recvStr();

        Assert.assertEquals(pong, "pong");

        // Everything should be cleanly closed now
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
        sock.connect("tcp://127.0.0.1:6556");

        //  Earliest offset
        sock.sendMore("OFFSET");
        sock.send(ByteBuffer.allocate(8).putLong(-2).array());

        Msg status = sock.base().recv(0);
        assertTrue(status.hasMore());
        assertEquals(100, status.data()[0]);
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
        assertFalse(oldest.hasMore());
        assertEquals(infos[0].start(), oldest.buf().getLong());

        //  Latest offset
        sock.sendMore("OFFSET");
        sock.send(ByteBuffer.allocate(8).putLong(-1).array());

        status = sock.base().recv(0);
        assertTrue(status.hasMore());
        assertEquals(100, status.data()[0]);
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        assertFalse(last.hasMore());
        assertEquals(infos[infos.length - 1].offset(), last.buf().getLong());

        //  Modified before
        sock.sendMore("OFFSET");
        sock.send(ByteBuffer.allocate(8).putLong(System.currentTimeMillis()).array());

        status = sock.base().recv(0);
        assertTrue(status.hasMore());
        assertEquals(100, status.data()[0]);
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
        sock.connect("tcp://127.0.0.1:6556");

        //  Latest offset
        sock.sendMore("FETCH");
        sock.sendMore(ByteBuffer.allocate(8).putLong(last.start()).array());
        sock.send(ByteBuffer.allocate(8).putLong(Integer.MAX_VALUE).array());

        Msg status = sock.base().recv(0);
        assertEquals(100, status.data()[0]);

        Msg result = sock.base().recv(0);
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.