Package org.zeromq.ZMQ

Examples of org.zeromq.ZMQ.Poller.poll()

30
31
32
33
34
35
36
37
38
39
40
    byte[] message;

    //  Switch messages between sockets
    while (!Thread.currentThread().isInterrupted()) {     
      //  poll and memorize multipart detection
      items.poll();

      if (items.pollin(0)) {
        while (true) {
          // receive message
          message = frontend.recv(0);
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
      //  Poll front-end only if we have available workers
      if(worker_queue.size()>0)
        items.register(frontend, Poller.POLLIN);

      items.poll();

      //  Handle worker activity on backend
      if (items.pollin(0)) {

        //  Queue worker address for LRU routing
View Full Code Here
766
767
768
769
770
771
772
773
774
775
776
                        Server server = self.servers [serverNbr];
                        items.register (server.dealer, Poller.POLLIN);
                    }
                }

                if (items.poll (self.heartbeat) == -1)
                    break;              //  Context has been shut down

                //  Process incoming messages; either of these can
                //  throw events into the state machine
                if (items.pollin (0))
View Full Code Here
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064
                //  Calculate tickless timer, up to interval seconds
                long tickless = System.currentTimeMillis () + self.monitor;
                tickless = clientTickless (self.clients, tickless);

                //  Poll until at most next timer event
                long rc = items.poll (tickless - System.currentTimeMillis ());
                if (rc == -1)
                    break;              //  Context has been shut down

                //  Process incoming message from either socket
                if (items.pollin (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.