public class IntegrationTestRpcClient extends Object
| Constructor and Description |
|---|
IntegrationTestRpcClient() |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractRpcClient |
createRpcClient(Configuration conf,
boolean isSyncClient) |
void |
testRpcWithChaosMonkey(boolean isSyncClient) |
void |
testRpcWithChaosMonkeyWithAsyncClient() |
void |
testRpcWithChaosMonkeyWithSyncClient() |
void |
testRpcWithWriteThread() |
protected AbstractRpcClient createRpcClient(Configuration conf, boolean isSyncClient)
public void testRpcWithWriteThread()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void testRpcWithChaosMonkeyWithSyncClient()
throws Throwable
Throwablepublic void testRpcWithChaosMonkeyWithAsyncClient()
throws Throwable
Throwable