public class ResponseAwaiter
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static ResponseAwaiter |
onLink(Link link)
Do not reuse instances! After calling
waitForResponse(long) the
reply listener is deregistered! So you need to create a new instance. |
RplyEvent |
waitForResponse(long messageId)
This method blocks until the response for the passed message id is
received.
|
ResponseAwaiter |
withTimeout(long timeout,
java.util.concurrent.TimeUnit timeUnit) |
public static ResponseAwaiter onLink(Link link) throws java.io.IOException
waitForResponse(long)
the
reply listener is deregistered! So you need to create a new instance.link
- the Link to wait for a reply onjava.io.IOException
public ResponseAwaiter withTimeout(long timeout, java.util.concurrent.TimeUnit timeUnit)
public RplyEvent waitForResponse(long messageId) throws java.io.IOException
messageId
- java.io.IOException
Copyright © 2019. All rights reserved.