public class InprocMessaging extends Object
Constructor and Description |
---|
InprocMessaging() |
Modifier and Type | Method and 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) |
public static int acquireNewPort()
public static void sendMessage(int port, Object msg)
public static void sendMessageNoWait(int port, Object msg)
public static Object takeMessage(int port) throws InterruptedException
InterruptedException
public static Object pollMessage(int port)
public static void waitForReader(int port)
Copyright © 2023 The Apache Software Foundation. All rights reserved.