public class IntegrationTestRpcClient
extends java.lang.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 java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic void testRpcWithChaosMonkeyWithSyncClient()
throws java.lang.Throwable
java.lang.Throwablepublic void testRpcWithChaosMonkeyWithAsyncClient()
throws java.lang.Throwable
java.lang.Throwablepublic void testRpcWithChaosMonkey(boolean isSyncClient)
throws java.lang.Throwable
java.lang.Throwable