public interface AsyncDispatcher<S extends Message> extends AutoCloseable
MessageDispatcherFactory
.Modifier and Type | Method and Description |
---|---|
int |
getQueueSize()
Returns the number of messages that are currently queued
awaiting for dispatch.
|
CompletableFuture<S> |
send(S message)
Asynchronously send the given message and return a future
that is resolved once the message was successfully dispatched.
|
close
CompletableFuture<S> send(S message)
message
- the message to sendint getQueueSize()
Copyright © 2017. All rights reserved.