com.nhncorp.neptune.changelog
Class RpcUtil

java.lang.Object
  com.nhncorp.neptune.changelog.RpcUtil

public class RpcUtil
extends java.lang.Object

Constructor Summary

RpcUtil(NConfiguration conf, java.net.InetSocketAddress[] rpcAddressList)

Method Summary

java.lang.reflect.Method	buildRpcMethod(java.lang.String methodName, java.lang.Class... paramClasses)
java.net.InetAddress	getAddressAt(int index)
int	getMultiRpcCount()
java.lang.Object[]	multiParallelCall_v2(java.lang.reflect.Method method, java.lang.Object... objects)
java.lang.Object[]	multiParallelCall(java.lang.reflect.Method method, java.lang.Object... objects)
java.lang.Object[]	multiSerialCall(java.lang.reflect.Method method, java.lang.Object... objects)
java.lang.Object	singleCall(java.lang.reflect.Method rpcMethod, int index, java.lang.Object... objects)
void	singleOnewayCall(java.lang.reflect.Method rpcMethod, int index, java.lang.Object... objects)

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcUtil

public RpcUtil(NConfiguration conf,
               java.net.InetSocketAddress[] rpcAddressList)

Method Detail

buildRpcMethod

public java.lang.reflect.Method buildRpcMethod(java.lang.String methodName,
                                               java.lang.Class... paramClasses)
                                        throws java.io.IOException

Throws:

java.io.IOException

singleOnewayCall

public void singleOnewayCall(java.lang.reflect.Method rpcMethod,
                             int index,
                             java.lang.Object... objects)
                      throws java.io.IOException

Throws:

java.io.IOException

singleCall

public java.lang.Object singleCall(java.lang.reflect.Method rpcMethod,
                                   int index,
                                   java.lang.Object... objects)
                            throws java.io.IOException

Throws:

java.io.IOException

multiSerialCall

public java.lang.Object[] multiSerialCall(java.lang.reflect.Method method,
                                          java.lang.Object... objects)
                                   throws java.io.IOException

Throws:

java.io.IOException

multiParallelCall

public java.lang.Object[] multiParallelCall(java.lang.reflect.Method method,
                                            java.lang.Object... objects)
                                     throws java.io.IOException

Throws:

java.io.IOException

multiParallelCall_v2

public java.lang.Object[] multiParallelCall_v2(java.lang.reflect.Method method,
                                               java.lang.Object... objects)
                                        throws java.io.IOException

Throws:

java.io.IOException

getMultiRpcCount

public int getMultiRpcCount()

getAddressAt

public java.net.InetAddress getAddressAt(int index)