|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.nutch.ipc.Client
A client for an IPC service. IPC calls take a single Writable
as a
parameter, and return a Writable
as their value. A service runs on
a port and is defined by a parameter class and a value class.
Server
Field Summary | |
static Logger |
LOG
|
Constructor Summary | |
Client(Class valueClass)
Construct an IPC client whose values are of the given Writable
class. |
Method Summary | |
Writable[] |
call(Writable[] params,
InetSocketAddress[] addresses)
Makes a set of calls in parallel. |
Writable |
call(Writable param,
InetSocketAddress address)
Make a call, passing param , to the IPC server running at
address , returning the value. |
void |
setTimeout(int timeout)
Sets the timeout used for network i/o. |
void |
stop()
Stop all threads related to this client. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final Logger LOG
Constructor Detail |
public Client(Class valueClass)
Writable
class.
Method Detail |
public void stop()
public void setTimeout(int timeout)
public Writable call(Writable param, InetSocketAddress address) throws IOException
param
, to the IPC server running at
address
, returning the value. Throws exceptions if there are
network problems or if the remote code threw an exception.
IOException
public Writable[] call(Writable[] params, InetSocketAddress[] addresses) throws IOException
IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |