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
InterruptedExceptionpublic static Object pollMessage(int port)
public static void waitForReader(int port)
Copyright © 2021 The Apache Software Foundation. All rights reserved.