Package org.zeromq.ZMQ

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

34
35
36
37
38
39
40
41
42
43
44
        // receive message
        message = frontend.recv(0);
        more = frontend.hasReceiveMore();

        // proxy it
        backend.send(message, more ? ZMQ.SNDMORE : 0);
        if(!more){
          break;
        }
      }
    }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
    //  Second, synchronize with publisher
    Socket syncclient = context.socket(ZMQ.REQ);
    syncclient.connect("tcp://localhost:5562");

    //  - send a synchronization request
    syncclient.send("".getBytes(), 0);

    //  - wait for synchronization reply
    byte[] value = syncclient.recv(0);

    //  Third, get our updates and report how many we got
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
      public void run() {
        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.toString(), org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message);
         
        } catch (final Exception e) {
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        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.toString(), org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        final Socket socket = ZMQ.getSocket(org.zeromq.ZMQ.PUSH);
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl.toString(), org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
        }
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        try {
          socket.connect(addr);
          socket.send(zmqType, org.zeromq.ZMQ.SNDMORE);
          socket.send(senderUrl.toString(), org.zeromq.ZMQ.SNDMORE);
          socket.send(token, org.zeromq.ZMQ.SNDMORE);
          socket.send(message);
         
        } catch (final Exception e) {
          LOG.log(Level.WARNING, "Failed to send JSON through ZMQ", e);
        }
        socket.setLinger(-1);
View Full Code Here
10
11
12
13
14
15
16
17
18
19
20
    socket.bind("tcp://localhost:5000");

    while (!Thread.currentThread().isInterrupted()) {
      String request = socket.recvStr(0);
      System.out.println("Received request: [" + request + "].");
      socket.send("World", 0);
    }

    socket.close();
    context.term();
  }
View Full Code Here
8
9
10
11
12
13
14
15
16
17
18
    Socket socket = context.socket(ZMQ.REQ);
    socket.connect("tcp://localhost:5000");

    for (int i = 0; i < 10; i++) {
      socket.send("Hello", 0);
      String reply = socket.recvStr(0);
      System.out.println("Received reply " + i + " [" + reply + "]");
    }

    socket.close();
View Full Code Here
10
11
12
13
14
15
16
17
18
19
20
    socket.bind("tcp://localhost:5000");

    String[] topics = { "tech", "music", "design" };
    while (!Thread.currentThread().isInterrupted()) {
      for (int i = 0; i < topics.length; i++) {
        if (socket.send(topics[i], 0))
          System.out.println("Publish: " + topics[i]);
      }
    }

    socket.close();
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.