public class Receiver
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
Receiver.Command<T> |
static class |
Receiver.ExternalAddress<T>
Retrieve the external address of this Receiver (i.e.
|
static class |
Receiver.ExternalAddress$ |
static class |
Receiver.GetAll<T>
Retrieve all messages from the Receiver that it has queued after the given
duration has elapsed.
|
static class |
Receiver.GetAll$ |
static class |
Receiver.GetAllResult<T> |
static class |
Receiver.GetAllResult$ |
static class |
Receiver.GetOne<T>
Retrieve one message from the Receiver, waiting at most for the given duration.
|
static class |
Receiver.GetOne$ |
static class |
Receiver.GetOneResult<T> |
static class |
Receiver.GetOneResult$ |
static interface |
Receiver.InternalCommand<T> |
static class |
Receiver.ReceiveTimeout<T> |
static class |
Receiver.ReceiveTimeout$ |
static interface |
Receiver.Replies<T> |
Constructor and Description |
---|
Receiver() |
Modifier and Type | Method and Description |
---|---|
static <T> Behavior<Receiver.Command<T>> |
behavior() |
public static <T> Behavior<Receiver.Command<T>> behavior()