backtype.storm.drpc
Class DRPCInvocationsClient

java.lang.Object
  backtype.storm.drpc.DRPCInvocationsClient

public class DRPCInvocationsClient
extends java.lang.Object

Constructor Summary

DRPCInvocationsClient(java.lang.String host, int port)

Method Summary

void	close()
void	failRequest(java.lang.String id)
DRPCRequest	fetchRequest(java.lang.String func)
java.lang.String	getHost()
int	getPort()
void	result(java.lang.String id, java.lang.String result)

Methods inherited from class java.lang.Object

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

Constructor Detail

DRPCInvocationsClient

public DRPCInvocationsClient(java.lang.String host,
                             int port)

Method Detail

getHost

public java.lang.String getHost()

getPort

public int getPort()

result

public void result(java.lang.String id,
                   java.lang.String result)
            throws TException

Throws:

TException

fetchRequest

public DRPCRequest fetchRequest(java.lang.String func)
                         throws TException

Throws:

TException

failRequest

public void failRequest(java.lang.String id)
                 throws TException

Throws:

TException

close

public void close()