org.xbib.elasticsearch.river.jdbc.strategy.column

Class AbstractColumnRiverTest

java.lang.Object

org.testng.Assert

org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

Direct Known Subclasses:

ColumnRiverFlowTests, ColumnRiverSourceTests

public abstract class AbstractColumnRiverTest
extends AbstractNodeTestHelper

Field Summary

Fields

Modifier and Type	Field and Description
protected static ColumnRiverContext	context
protected static ColumnRiverSource	source

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

cluster, index, logger, type

Constructor Summary

Constructors

Constructor and Description
AbstractColumnRiverTest()

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	createRiver(String resource)
abstract ColumnRiverContext	newRiverContext()
abstract ColumnRiverSource	newRiverSource()
protected void	performRiver(String resource)
protected org.elasticsearch.river.RiverSettings	riverSettings(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 ColumnRiverSource source

context

protected static ColumnRiverContext context

Constructor Detail

AbstractColumnRiverTest

public AbstractColumnRiverTest()

Method Detail

newRiverSource

public abstract ColumnRiverSource newRiverSource()

newRiverContext

public abstract ColumnRiverContext 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

riverSettings

protected org.elasticsearch.river.RiverSettings riverSettings(String resource)
                                                       throws IOException

Throws:

IOException

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