org.ardulink.core.qos

Class ResponseAwaiter

java.lang.Object

org.ardulink.core.qos.ResponseAwaiter

public class ResponseAwaiter
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static ResponseAwaiter	onLink(Link link) Do not reuse instances!
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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

onLink

public static ResponseAwaiter onLink(Link link)
                              throws java.io.IOException

Do not reuse instances! After calling waitForResponse(long) the reply listener is deregistered! So you need to create a new instance.

Parameters:

link - the Link to wait for a reply on

Throws:

java.io.IOException

withTimeout

public ResponseAwaiter withTimeout(long timeout,
                                   java.util.concurrent.TimeUnit timeUnit)

waitForResponse

public RplyEvent waitForResponse(long messageId)
                          throws java.io.IOException

This method blocks until the response for the passed message id is received.

Parameters:

messageId -

Returns:

Throws:

java.io.IOException