Package org.apache.storm.utils
Class InprocMessaging
java.lang.Object
org.apache.storm.utils.InprocMessaging
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic int
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)
-
Constructor Details
-
InprocMessaging
public InprocMessaging()
-
-
Method Details
-
acquireNewPort
public static int acquireNewPort() -
sendMessage
-
sendMessageNoWait
-
takeMessage
- Throws:
InterruptedException
-
pollMessage
-
waitForReader
public static void waitForReader(int port)
-