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

        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/hello.txt"), new ByteArrayInputStream(
                "hello, world".getBytes()));


        // verifications
        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        assertThatNode(repo, poller, "/test", allOf(hasPath("/test"), hasPrimaryType("nt:folder"), hasChildrenCount(1)));


        // change node type to sling:Folder
        InputStream contentXml = getClass().getResourceAsStream("sling-folder-nodetype.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/.content.xml"), contentXml);

View Full Code Here

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

        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/hello.esp"), new ByteArrayInputStream(
                "// not really javascript".getBytes()));


        // verify that file is created
        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        assertThatNode(repo, poller, "/test/hello.esp", hasPrimaryType("nt:file"));


        InputStream contentXml = getClass().getResourceAsStream("file-custom-mimetype.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/hello.esp.dir/.content.xml"), contentXml);

View Full Code Here

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

        ServerAdapter server = new ServerAdapter(wstServer.getServer());
        server.installModule(contentProject);


        // verify that file is created
        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/test/hello.txt");
            }
        }, hasFileContent("hello, world"));

View Full Code Here

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

        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/demo/nested/structure/hello.txt"),
                new ByteArrayInputStream("hello, world".getBytes()));


        // verify that file is created
        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/test/demo/nested/structure/hello.txt");
            }
        }, hasFileContent("hello, world"));

View Full Code Here

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

        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/folder/config.xml"), getClass()
                .getResourceAsStream("com.example.some.Component.xml"));


        // verify that config node is created
        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();


        assertThatNode(repo, poller, "/test/folder/config", hasPrimaryType("sling:OsgiConfig"));


        // update file at /test/folder/hello.esp
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/test/folder/hello.esp"), new ByteArrayInputStream(

View Full Code Here

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


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root"), hasPrimaryType("sling:Folder"),
                hasChildrenCount(1));


        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");


            }
        }, postConditions);


        // update jcr:title for /content/test-root
        InputStream updatedContentXml = getClass().getResourceAsStream("sling-folder-nodetype-with-title.xml");
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/.content.xml"),
                updatedContentXml);


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


            }

View Full Code Here

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


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root/nested"), hasPrimaryType("nt:unstructured"),
                hasChildrenCount(1));


        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/nested");


            }
        }, postConditions);


        // update jcr:title for /content/test-root
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/nested/.content.xml"),
                getClass().getResourceAsStream("nt-unstructured-nodetype-with-title.xml"));


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


            }

View Full Code Here

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


        Matcher<Node> postConditions = allOf(hasPath("/content/test-root"), hasPrimaryType("sling:OrderedFolder"),
                hasChildrenNames("folder", "jcr:content"));


        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");


            }
        }, postConditions);


        // reorder the children of the /content/test-root node
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/.content.xml"), getClass()
                .getResourceAsStream("sling-ordered-folder-with-children-reordered.xml"));


        postConditions = allOf(hasPath("/content/test-root"), hasPrimaryType("sling:OrderedFolder"),
                hasChildrenNames("jcr:content", "folder"));


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


            }

View Full Code Here

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

        // first create the local structure where the content is completely serialized inside the .content.xml file
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/mapping/.content.xml"),
                getClass().getResourceAsStream("sling-mapping-with-folder-child.xml"));


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();


        // wait until the structure is published
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/mapping/jcr:content/par");


            }
        }, hasPrimaryType("nt:unstructured"));


        // now create the folder and its associated .content.xml file ; this will cause
        // intermediate folders to be created whose serialization data is present in the
        // parent's .content.xml file
        project.createOrUpdateFile(
                Path.fromPortableString("jcr_root/content/test-root/mapping/_jcr_content/par/folder/.content.xml"),
                getClass().getResourceAsStream("sling-folder-nodetype.xml"));


        // first wait until the sling:Folder child node is created, to ensure that all changes are processed
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/mapping/jcr:content/par/folder");


            }
        }, hasPrimaryType("sling:Folder"));


        // then, verify that the nt:unstructured node is correctly written
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/mapping/jcr:content/par");


            }

View Full Code Here

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

        project.createOrUpdateFile(
                Path.fromPortableString("jcr_root/content/test-root/mapping/_jcr_content/par/folder/.content.xml"),
                getClass().getResourceAsStream("sling-folder-nodetype.xml"));        


        final RepositoryAccessor repo = new RepositoryAccessor(config);
        Poller poller = new Poller();


        // wait until the structure is published
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/mapping/jcr:content/par/folder");


            }
        }, hasPrimaryType("sling:Folder"));


        // change the folder's node type to nt:unstructured and make sure it's covered by the parent
        project.createOrUpdateFile(Path.fromPortableString("jcr_root/content/test-root/mapping/.content.xml"),
                getClass().getResourceAsStream("sling-mapping-with-unstructured-child.xml"));
        // delete the sling folder node type since the serialization is now completely covered by
        // the parent node
        project.deleteMember(Path.fromPortableString("jcr_root/content/test-root/mapping/_jcr_content"));


        // first wait until the sling:Folder child node is created, to ensure that all changes are processed
        poller.pollUntil(new Callable<Node>() {
            @Override
            public Node call() throws RepositoryException {
                return repo.getNode("/content/test-root/mapping/jcr:content/par/folder");


            }

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.