enqueue

fun enqueue(key: Any, namedAggregate: NamedAggregate, context: ContextView = Context.empty(), description: () -> String, send: (admitted: Boolean) -> Mono<Void>): LocalFirstDistributedCopies.Copy

Queues the copy of a message of the aggregate key (its aggregate ID), sent by send with the local decision once every earlier copy of that aggregate was sent, in the sender's context.