backtype.storm.utils

Class InprocMessaging

java.lang.Object

backtype.storm.utils.InprocMessaging

public class InprocMessaging
extends Object

Constructor Summary

Constructors

Constructor and Description
InprocMessaging()

Method Summary

Methods

Modifier and Type	Method and Description
static int	acquireNewPort()
static Object	pollMessage(int port)
static void	sendMessage(int port, Object msg)
static 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,
               Object msg)

takeMessage

public static Object takeMessage(int port)
                          throws InterruptedException

Throws:

InterruptedException

pollMessage

public static Object pollMessage(int port)