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

  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)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### InprocMessaging

    public InprocMessaging()

- ## Method Details

  - ### 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)