Till Westmann has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/1897
Change subject: [ING] Add RSS test using external test feed ...................................................................... [ING] Add RSS test using external test feed - user model changes: no - storage format changes: no - interface changes: no details: - use a simple feed from http://lorem-rss.herokuapp.com/ Change-Id: Ia020052efbe0fe0de5f78017202f3f7d61b7bff3 --- M asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/input/record/reader/RSSRecordReaderTest.java 1 file changed, 23 insertions(+), 0 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/97/1897/1 diff --git a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/input/record/reader/RSSRecordReaderTest.java b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/input/record/reader/RSSRecordReaderTest.java index ca94a3f..5033b55 100644 --- a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/input/record/reader/RSSRecordReaderTest.java +++ b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/input/record/reader/RSSRecordReaderTest.java @@ -18,6 +18,8 @@ */ package org.apache.asterix.external.input.record.reader; +import com.rometools.rome.feed.synd.SyndEntry; +import org.apache.asterix.external.api.IRawRecord; import org.apache.asterix.external.input.record.reader.rss.RSSRecordReader; import org.junit.Assert; import org.junit.Test; @@ -39,4 +41,25 @@ Assert.assertNotNull(expectedException); Assert.assertTrue(expectedException.getMessage().contains("UnknownHostException")); } + + private static final int NO_RECORDS = 10; + + @Test + public void fetchFromLoremWebsite() throws MalformedURLException { + String dummyRssFeedURL = "http://lorem-rss.herokuapp.com/feed";; + RSSRecordReader rssRecordReader = new RSSRecordReader(dummyRssFeedURL); + Exception expectedException = null; + int cnt = 0; + try { + while (rssRecordReader.hasNext() && cnt < NO_RECORDS) { + IRawRecord<SyndEntry> rec = rssRecordReader.next(); + ++cnt; + Assert.assertTrue(rec.get().getTitle().startsWith("Lorem ipsum")); + } + } catch (Exception e) { + expectedException = e; + } + Assert.assertEquals(cnt, NO_RECORDS); + Assert.assertNull(expectedException); + } } -- To view, visit https://asterix-gerrit.ics.uci.edu/1897 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: Ia020052efbe0fe0de5f78017202f3f7d61b7bff3 Gerrit-PatchSet: 1 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Till Westmann <[email protected]>
