Package org.apache.storm.utils

Class InprocMessaging

java.lang.Object

org.apache.storm.utils.InprocMessaging

public class InprocMessaging
extends Object

Constructor Summary

Constructors

Constructor	Description
InprocMessaging()

Method Summary

Modifier and Type	Method	Description
static int	acquireNewPort()
static Object	pollMessage(int port)
static void	sendMessage(int port, Object msg)
static void	sendMessageNoWait(int port, Object msg)
static Object	takeMessage(int port)
static void	waitForReader(int port)

Methods inherited from class java.lang.Object

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

Constructor Details

InprocMessaging

public InprocMessaging()

Method Details

acquireNewPort

public static int acquireNewPort()

sendMessage

public static void sendMessage(int port,
 Object msg)

sendMessageNoWait

public static void sendMessageNoWait(int port,
 Object msg)

takeMessage

public static Object takeMessage(int port)
                          throws InterruptedException

Throws:

InterruptedException

pollMessage

public static Object pollMessage(int port)

waitForReader

public static void waitForReader(int port)