Class LocalDRPC

java.lang.Object
org.apache.storm.LocalDRPC
All Implemented Interfaces:
AutoCloseable, Shutdownable, DistributedRPC.Iface, DistributedRPCInvocations.Iface, ILocalDRPC

public class LocalDRPC extends Object implements ILocalDRPC
A Local way to test DRPC.

try (LocalDRPC drpc = new LocalDRPC()) { // Do tests }