backtype.storm.utils
Class InprocMessaging

java.lang.Object
  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)