public interface AsyncDispatcher<S extends Message> extends AutoCloseable
MessageDispatcherFactory
.Modifier and Type | Interface and Description |
---|---|
static class |
AsyncDispatcher.DispatchStatus |
Modifier and Type | Method and Description |
---|---|
int |
getQueueSize()
Returns the number of messages that are currently queued
awaiting for dispatch.
|
CompletableFuture<AsyncDispatcher.DispatchStatus> |
send(S message)
Asynchronously send the given message.
|
close
CompletableFuture<AsyncDispatcher.DispatchStatus> send(S message)
message
- the message to sendint getQueueSize()
Copyright © 2020. All rights reserved.