001package org.xbib.elasticsearch.river.jdbc.strategy.simple;
002
003import org.testng.annotations.Parameters;
004import org.testng.annotations.Test;
005import org.xbib.elasticsearch.river.jdbc.RiverSource;
006
007public class SimpleRiverScriptTests extends AbstractSimpleRiverTest {
008
009    @Override
010    public RiverSource newRiverSource() {
011        return new SimpleRiverSource();
012    }
013
014    @Override
015    public SimpleRiverContext newRiverContext() {
016        return new SimpleRiverContext();
017    }
018
019    /**
020     * Orders table (star query)
021     *
022     * @param riverResource the river definition
023     * @throws Exception if test fails
024     */
025    @Test
026    @Parameters({"river1"})
027    public void testSimpleRiverOnce(String riverResource) throws Exception {
028        createRiver(riverResource);
029        waitForInactiveRiver();
030    }
031
032}