public class TestRowProcessorEndpoint
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
TestRowProcessorEndpoint.RowProcessorEndpoint<S extends Message,T extends Message>
This class defines two RowProcessors:
IncrementCounterProcessor and FriendsOfFriendsProcessor.
|
| Constructor and Description |
|---|
TestRowProcessorEndpoint() |
| Modifier and Type | Method and Description |
|---|---|
void |
prepareTestData() |
static void |
setupBeforeClass() |
static void |
tearDownAfterClass() |
void |
testDoubleScan() |
void |
testMultipleRows() |
void |
testReadModifyWrite() |
void |
testTimeout() |
public static void setupBeforeClass()
throws java.lang.Exception
java.lang.Exceptionpublic static void tearDownAfterClass()
throws java.lang.Exception
java.lang.Exceptionpublic void prepareTestData()
throws java.lang.Exception
java.lang.Exceptionpublic void testDoubleScan()
throws java.lang.Throwable
java.lang.Throwablepublic void testReadModifyWrite()
throws java.lang.Throwable
java.lang.Throwablepublic void testMultipleRows()
throws java.lang.Throwable
java.lang.Throwablepublic void testTimeout()
throws java.lang.Throwable
java.lang.Throwable