backtype.storm.utils
Class InprocMessaging

java.lang.Object
  extended by backtype.storm.utils.InprocMessaging

public class InprocMessaging
extends java.lang.Object


Constructor Summary
InprocMessaging()
           
 
Method Summary
static int acquireNewPort()
           
static java.lang.Object pollMessage(int port)
           
static void sendMessage(int port, java.lang.Object msg)
           
static java.lang.Object takeMessage(int port)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InprocMessaging

public InprocMessaging()
Method Detail

acquireNewPort

public static int acquireNewPort()

sendMessage

public static void sendMessage(int port,
                               java.lang.Object msg)

takeMessage

public static java.lang.Object takeMessage(int port)
                                    throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

pollMessage

public static java.lang.Object pollMessage(int port)