Class InprocMessaging

java.lang.Object
org.apache.storm.utils.InprocMessaging

public class InprocMessaging extends Object
  • 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)