public interface RequestSender
Modifier and Type | Method and Description |
---|---|
RequestSender |
onAgree(java.util.function.Consumer<Message> consumer)
Adds a message consumer to be invoked when an AGREE response is received.
|
RequestSender |
onFailure(java.util.function.Consumer<Message> consumer)
Adds a message consumer to be invoked when a FAILURE response is received.
|
RequestSender |
onInform(java.util.function.Consumer<Message> consumer)
Adds a message consumer to be invoked when an INFORM message is received.
|
RequestSender |
onRefuse(java.util.function.Consumer<Message> consumer)
Adds a message consumer to be invoked when a REFUSE response is received.
|
RequestSender |
onTimeout(long timeout,
java.lang.Runnable runnable)
Adds a Runnable to be invoked when this operation times out.
|
RequestSender |
otherwise(java.util.function.Consumer<Message> consumer)
Adds a message consumer to be invoked when a message that is not one of AGREE, REFUSE, FAILURE, INFORM is received.
|
java.util.concurrent.Future<Message> |
send()
Sends the message asynchronously.
|
Message |
sendAndWait()
Sends the message synchronously.
|
RequestSender onAgree(java.util.function.Consumer<Message> consumer)
consumer
- Message consumer.RequestSender onRefuse(java.util.function.Consumer<Message> consumer)
consumer
- Message consumer.RequestSender onFailure(java.util.function.Consumer<Message> consumer)
consumer
- Message consumer.RequestSender onInform(java.util.function.Consumer<Message> consumer)
consumer
- Message consumer.RequestSender onTimeout(long timeout, java.lang.Runnable runnable)
timeout
- Timeout (ms).runnable
- Runnable.RequestSender otherwise(java.util.function.Consumer<Message> consumer)
consumer
- Message consumer.java.util.concurrent.Future<Message> send()
Message sendAndWait()