Examples of Poller

com.funambol.syncclient.blackberry.email.impl.Poller
Poller class polling for notifications
com.github.restdriver.serverdriver.polling.Poller
For making asynchronous assertions.

For typical use, create an anonymous subclass inline, and implement the {@link #poll()} method:
```
 {@code}new Poller( times(10), every(100, MILLISECONDS) )  public void poll() { assertThat(someMethodCall(), is("Success")); } }; } 
```
This assertion will be called a number of times (configurable by using the different constructors). The first poll is tried immediately, so if you specify 3 attempts with 1 second pause, the total execution time will be about 2 seconds.

This class catches any {@link AssertionError} thrown in the first n-1 attempts. If any other kind of Exception is encountered, or an AssertionError is thrown at the last attempt then itwill be thrown immediately and your test will fail. All AssertionErrors except the last are swallowed.

For debugging purposes you may call {@link #loudly()} in your poll method, and interim AssertionErrors will be logged to System.out rather than being simply ignored.
com.salas.bb.utils.poller.Poller
Poller takes care of periodical feeds updates. It makes regular scans of the feeds lists attempting to find the feeds requiring to be updated. The period of these scans is defined by scanPeriod property.

Poller is always dedicated to some guides set and works only with it. This decision was made to simplify scanning of feeds and does not limit the functionality as the application always have only one active guide set.

This class has convenient methods to force updates of the feeds out of the schedule. They are:
- update() - updates all feeds (indirectly) in all guides.
- update(IGuide) - updates all feeds (indirectly) in given guide.
- update(IFeed) - updates the feed. The feed can be updated directly (meaning that the updating of this particular feed is required) or indirectly (meaning that the updating of the feed happens as a part of bigger update: guide or whole set).
Before actually doing the update Poller asks each of the feeds whether they can be updated or not. The feed decides, taking in account the fact of direct or indirect call, last poll date and other factors, if it would like to be updated. If it would like to then the Poller puts the feed in queue for updates.

Poller owns some number of worker threads which are waiting for the tasks in the queue. Once they grab the task from the queue, they follow update procedure. After they finish they move back to the fetching of the next task.
org.apache.sling.ide.test.impl.helpers.Poller
org.apache.tomcat.util.net.AprEndpoint.Poller
org.apache.tomcat.util.net.NioEndpoint.Poller
org.zeromq.ZMQ.Poller

Examples of org.zeromq.ZMQ.Poller

      pipe.send("READY"); // optional


      Socket snapshot = ctx.createSocket(ZMQ.ROUTER);
      snapshot.bind("tcp://*:5556");


      Poller poller = new ZMQ.Poller(2);
      poller.register(pipe, ZMQ.Poller.POLLIN);
      poller.register(snapshot, ZMQ.Poller.POLLIN);


      long stateSequence = 0;
      while (!Thread.currentThread().isInterrupted()) {
        if (poller.poll() < 0)
                    break;              //  Context has been shut down


        // apply state updates from main thread
        if (poller.pollin(0)) {
          kvsimple kvMsg = kvsimple.recv(pipe);
                    if (kvMsg == null)
                        break;
          StateManager.kvMap.put(kvMsg.getKey(), kvMsg);
          stateSequence = kvMsg.getSequence();
        }


        // execute state snapshot request
        if (poller.pollin(1)) {
          byte[] identity = snapshot.recv(0);
                    if (identity == null)
                        break;
          String request = new String(snapshot.recv(0));

View Full Code Here

Examples of org.zeromq.ZMQ.Poller

        //  us an API that does more with fewer calls:


        while (!Thread.currentThread().isInterrupted()) {


            //  Initialize poll set
            Poller items = new Poller (2);


            //  Always poll for worker activity on backend
            items.register(backend, Poller.POLLIN);


            //  Poll front-end only if we have available workers
            if(workerQueue.size() > 0)
                items.register(frontend, Poller.POLLIN);


            if (items.poll() < 0)
                break;      //  Interrupted


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


                ZMsg msg = ZMsg.recvMsg (backend);
                if (msg == null)
                    break;  //  Interrupted


                ZFrame identity = msg.unwrap ();
                //  Queue worker address for LRU routing
                workerQueue.add (identity);


                //  Forward message to client if it's not a READY
                ZFrame frame = msg.getFirst ();
                if (Arrays.equals (frame.getData (), WORKER_READY))
                    msg.destroy ();
                else
                    msg.send (frontend);
            }


            if (items.pollin(1)) {
                //  Get client request, route to first available worker
                ZMsg msg = ZMsg.recvMsg (frontend);
                if (msg != null) {
                    msg.wrap (workerQueue.poll ());
                    msg.send (backend);

View Full Code Here

0 1 2 3 4 5

TOP

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.