Package org.apache.storm.utils
Class InprocMessaging
java.lang.Object
org.apache.storm.utils.InprocMessaging
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic intstatic ObjectpollMessage(int port) static voidsendMessage(int port, Object msg) static voidsendMessageNoWait(int port, Object msg) static ObjecttakeMessage(int port) static voidwaitForReader(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)
-