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.apache.sling.ide.test.impl.helpers.Poller


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(3));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(3));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }
        }, postConditions);


        // update .content.xml structure
        InputStream updatedContentXml = getClass().getResourceAsStream("content-nested-structure-deleted-node.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/en.xml"), updatedContentXml);


        // poll until we only have 2 child nodes left
        postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(2));
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(3));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }
        }, postConditions);


        // update .content.xml structure
        InputStream updatedContentXml = getClass()
                .getResourceAsStream("content-nested-structure-deleted-all-nodes.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/en.xml"), updatedContentXml);


        // poll until we only have no child nodes left
        postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(0));
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenNames("message", "error", "warning"));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }
        }, postConditions);


        // update .content.xml structure
        InputStream updatedContentXml = getClass().getResourceAsStream("content-nested-structure-reordered-nodes.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/en.xml"), updatedContentXml);


        // poll until we have the child nodes reordered
        postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:OrderedFolder"),
                hasMixinTypes("mix:language"), hasChildrenNames("message", "warning", "error"));


        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller

        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/en.xml"), contentXml);


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/en"), hasPrimaryType("sling:Folder"),
                hasMixinTypes("mix:language"), hasChildrenCount(3));


        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/en");


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/" + baseName),
                hasPrimaryType("sling:OsgiConfig"));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/" + baseName);


            }
        }, postConditions);


        // Remove file from disk
        project.deleteMember(Path.fromPortableString("jcr_root/content/test-root/" + baseName + ".xml"));


        // poll until the node no longer exists
        poller.pollUntil(new Callable<Boolean>() {
            @Override
            public Boolean call() throws RepositoryException {
                return repo.hasNode("/content/test-root/" + baseName);


            }

View Full Code Here

Examples of org.apache.sling.ide.test.impl.helpers.Poller

        OsgiBundleManifest mf = new OsgiBundleManifest("com.example.bundle001").version("1.0.0").serviceComponent(
                serviceComponentHeader);


        project.createOsgiBundleManifest(mf);


        poller = new Poller();
        poller.pollUntil(new Callable<IProject>() {


            @Override
            public IProject call() throws Exception {
                return projectRule.getProject();

View Full Code Here

Examples of org.apache.tomcat.util.net.AprEndpoint.Poller

                            socket.getSocket().longValue(),
                            SocketStatus.STOP);
                }
            } else {
                // Upgraded
                Poller p = ((AprEndpoint) proto.endpoint).getPoller();
                if (p == null) {
                    // Connector has been stopped
                    release(socket, processor, true, false);
                } else {
                    p.add(socket.getSocket().longValue(), -1, true, false);
                }
            }
        }

View Full Code Here

Examples of org.apache.tomcat.util.net.AprEndpoint.Poller

                            socket.getSocket().longValue(),
                            SocketStatus.STOP);
                }
            } else if (processor.isUpgrade()) {
                // Upgraded
                Poller p = ((AprEndpoint) proto.endpoint).getPoller();
                if (p == null) {
                    // Connector has been stopped
                    release(socket, processor, true, false);
                } else {
                    p.add(socket.getSocket().longValue(), -1, true, false);
                }
            } else {
                // Tomcat 7 proprietary upgrade
                ((AprEndpoint) proto.endpoint).getPoller().add(
                        socket.getSocket().longValue(),

View Full Code Here

Examples of org.apache.tomcat.util.net.AprEndpoint.Poller

                            socket.getSocket().longValue(),
                            SocketStatus.STOP);
                }
            } else {
                // Upgraded
                Poller p = ((AprEndpoint) proto.endpoint).getPoller();
                if (p == null) {
                    // Connector has been stopped
                    release(socket, processor, true, false);
                } else {
                    p.add(socket.getSocket().longValue(), -1, true, false);
                }
            }
        }

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.