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
All Methods Static Methods Concrete Methods 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)
-
-
-
Method Detail
-
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)
-
-