org.apache.storm

Class LocalDRPC

java.lang.Object

org.apache.storm.LocalDRPC

All Implemented Interfaces:

Shutdownable, DistributedRPC.Iface, DistributedRPCInvocations.Iface, ILocalDRPC

public class LocalDRPC
extends Object
implements ILocalDRPC

Constructor Summary

Constructors

Constructor and Description
LocalDRPC()

Method Summary

Modifier and Type	Method and Description
String	execute(String functionName, String funcArgs)
void	failRequest(String id)
DRPCRequest	fetchRequest(String functionName)
String	getServiceId()
void	result(String id, String result)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalDRPC

public LocalDRPC()

Method Detail

getServiceId

public String getServiceId()

Specified by:

getServiceId in interface ILocalDRPC

result

public void result(String id,
                   String result)
            throws AuthorizationException,
                   org.apache.thrift.TException

Specified by:

result in interface DistributedRPCInvocations.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

execute

public String execute(String functionName,
                      String funcArgs)
               throws DRPCExecutionException,
                      AuthorizationException,
                      org.apache.thrift.TException

Specified by:

execute in interface DistributedRPC.Iface

Throws:

DRPCExecutionException

AuthorizationException

org.apache.thrift.TException

failRequest

public void failRequest(String id)
                 throws AuthorizationException,
                        org.apache.thrift.TException

Specified by:

failRequest in interface DistributedRPCInvocations.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

shutdown

public void shutdown()

Specified by:

shutdown in interface Shutdownable

fetchRequest

public DRPCRequest fetchRequest(String functionName)
                         throws AuthorizationException,
                                org.apache.thrift.TException

Specified by:

fetchRequest in interface DistributedRPCInvocations.Iface

Throws:

AuthorizationException

org.apache.thrift.TException