Package org.apache.storm.utils
Class InprocMessaging
java.lang.Object
org.apache.storm.utils.InprocMessaging
- 
Constructor SummaryConstructors
- 
Method SummaryModifier 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- 
InprocMessagingpublic InprocMessaging()
 
- 
- 
Method Details- 
acquireNewPortpublic static int acquireNewPort()
- 
sendMessage
- 
sendMessageNoWait
- 
takeMessage- Throws:
- InterruptedException
 
- 
pollMessage
- 
waitForReaderpublic static void waitForReader(int port) 
 
-