org.xbib.elasticsearch.river.jdbc.strategy.simple

Class AbstractSimpleRiverTest

java.lang.Object

org.testng.Assert

org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

Direct Known Subclasses:

RiverMockTests, SimpleRiverDataTests, SimpleRiverJobTests, SimpleRiverScheduleTests, SimpleRiverScriptTests, SimpleRiverSourceTests, SimpleRiverStoredProcedureTests

public abstract class AbstractSimpleRiverTest
extends AbstractNodeTestHelper

Field Summary

Fields

Modifier and Type	Field and Description
protected static RiverContext	context
protected static RiverSource	source

Fields inherited from class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

cluster, index, logger, type

Constructor Summary

Constructors

Constructor and Description
AbstractSimpleRiverTest()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterMethod(String stopurl, String user, String password, String resourceName)
void	beforeMethod(String starturl, String user, String password, String resourceName)
protected void	createRandomProducts(String sql, int size)
protected void	createRandomProductsJob(String sql, int size)
protected void	createRiver(String resource)
protected void	createTimestampedLogs(String sql, int size, String locale, String timezone)
abstract RiverContext	newRiverContext()
abstract RiverSource	newRiverSource()
protected void	performRiver(String resource)
void	waitForActiveRiver()
static RiverState	waitForActiveRiver(org.elasticsearch.client.Client client, String riverName, String riverType, int seconds)
void	waitForInactiveRiver()
static RiverState	waitForInactiveRiver(org.elasticsearch.client.Client client, String riverName, String riverType, int seconds)
void	waitForRiver()
static RiverState	waitForRiver(org.elasticsearch.client.Client client, String riverName, String riverType, int seconds)

Methods inherited from class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

assertHits, assertTimestampSort, buildNode, client, getClusterName, getNodeSettings, setClusterName, startNode, startNodes, stopNodes, waitForYellow

Methods inherited from class org.testng.Assert

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsNoOrder, assertEqualsNoOrder, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, fail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

source

protected static RiverSource source

context

protected static RiverContext context

Constructor Detail

AbstractSimpleRiverTest

public AbstractSimpleRiverTest()

Method Detail

newRiverSource

public abstract RiverSource newRiverSource()

newRiverContext

public abstract RiverContext newRiverContext()

beforeMethod

public void beforeMethod(String starturl,
                String user,
                String password,
                String resourceName)
                  throws Exception

Throws:

Exception

afterMethod

public void afterMethod(String stopurl,
               String user,
               String password,
               String resourceName)
                 throws Exception

Throws:

Exception

performRiver

protected void performRiver(String resource)
                     throws Exception

Throws:

Exception

createRiver

protected void createRiver(String resource)
                    throws Exception

Throws:

Exception

waitForRiver

public void waitForRiver()
                  throws Exception

Throws:

Exception

waitForActiveRiver

public void waitForActiveRiver()
                        throws Exception

Throws:

Exception

waitForInactiveRiver

public void waitForInactiveRiver()
                          throws Exception

Throws:

Exception

createRandomProducts

protected void createRandomProducts(String sql,
                        int size)
                             throws SQLException

Throws:

SQLException

createTimestampedLogs

protected void createTimestampedLogs(String sql,
                         int size,
                         String locale,
                         String timezone)
                              throws SQLException

Throws:

SQLException

createRandomProductsJob

protected void createRandomProductsJob(String sql,
                           int size)
                                throws SQLException

Throws:

SQLException

waitForRiver

public static RiverState waitForRiver(org.elasticsearch.client.Client client,
                      String riverName,
                      String riverType,
                      int seconds)
                               throws InterruptedException,
                                      IOException

Throws:

InterruptedException

IOException

waitForActiveRiver

public static RiverState waitForActiveRiver(org.elasticsearch.client.Client client,
                            String riverName,
                            String riverType,
                            int seconds)
                                     throws InterruptedException,
                                            IOException

Throws:

InterruptedException

IOException

waitForInactiveRiver

public static RiverState waitForInactiveRiver(org.elasticsearch.client.Client client,
                              String riverName,
                              String riverType,
                              int seconds)
                                       throws InterruptedException,
                                              IOException

Throws:

InterruptedException

IOException