Package com.google.appengine.api.prospectivesearch

Examples of com.google.appengine.api.prospectivesearch.ProspectiveSearchService.subscribe()


            ProspectiveSearchServiceFactory.getProspectiveSearchService();
        String topic = "HotMinutes";
        long leaseDurationSeconds = 0;
        Map<String, FieldType> schema = new HashMap<String, FieldType>();
        schema.put("memoCount", FieldType.INT32);
        prospectiveSearchService.subscribe(
            topic,
            "HotMinutes_25",
            leaseDurationSeconds,
            "memoCount = 25",
            schema);
View Full Code Here


            topic,
            "HotMinutes_25",
            leaseDurationSeconds,
            "memoCount = 25",
            schema);
        prospectiveSearchService.subscribe(
            topic,
            "HotMinutes_50",
            leaseDurationSeconds,
            "memoCount = 50",
            schema);
View Full Code Here

            topic,
            "HotMinutes_50",
            leaseDurationSeconds,
            "memoCount = 50",
            schema);
        prospectiveSearchService.subscribe(
            topic,
            "HotMinutes_100",
            leaseDurationSeconds,
            "memoCount = 100",
            schema);
View Full Code Here

    }

    @Test
    public void testTopicIsCreatedWhenFirstSubscriptionForTopicIsCreated() {
        ProspectiveSearchService pss = ProspectiveSearchServiceFactory.getProspectiveSearchService();
        pss.subscribe(TOPIC, "mySubscription", 0, "title:hello", createSchema("title", FieldType.STRING));
        assertTopicExists(TOPIC);
    }

    @Test
    public void testTopicIsRemovedWhenLastSubscriptionForTopicIsDeleted() {
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.