org.apache.flume.api
Class RpcClientFactory

java.lang.Object
  org.apache.flume.api.RpcClientFactory

public class RpcClientFactory
extends Object

Factory class to construct Flume RPCClient implementations.

Constructor Summary

RpcClientFactory()

Method Summary

static RpcClient	getInstance(String hostname, Integer port) Returns an instance of RpcClient connected to the specified hostname and port.
static RpcClient	getInstance(String hostname, Integer port, Integer batchSize) Returns an instance of RpcClient connected to the specified hostname and port with the specified batchSize.

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcClientFactory

public RpcClientFactory()

Method Detail

getInstance

public static RpcClient getInstance(String hostname,
                                    Integer port)
                             throws FlumeException

Returns an instance of RpcClient connected to the specified hostname and port.

Throws:

FlumeException

getInstance

public static RpcClient getInstance(String hostname,
                                    Integer port,
                                    Integer batchSize)
                             throws FlumeException

Returns an instance of RpcClient connected to the specified hostname and port with the specified batchSize.

Throws:

FlumeException