client/me.ahoo.wow.client.java/JavaCommandClient

JavaCommandClient

@JvmSuppressWildcards

class JavaCommandClient

The CommandClient for Java callers: the same calls, the in-process client's or a peer's over HTTP alike, without coroutines or Kotlin types. Each call is blocking (send, sendAndWait, stream) or asynchronous (sendAsync, sendAndWaitAsync); see JavaFlows for which thread runs them. Each takes a CommandRequest, or a command and the id of the aggregate it goes to (none for a creation), its type derived from the command's class.

JavaCommandClient commands = JavaCommandClient.of(commandClient).of(caller);
CommandResult result = commands.sendAndWait(new SubmitOrder(items));
commands.sendAndWait(CommandRequest.builder(new PayOrder(amount)).id(orderId).wait(WaitPlan.COMMITTED).build());

A rejection is a me.ahoo.wow.api.client.CommandRejectedException, a technical failure a me.ahoo.wow.api.problem.WowProblemException, both unchecked; an asynchronous call's future completes with them.

Types

object Companion

Functions

fun of(caller: Caller): JavaCommandClient

This client sending as caller (CommandClient.of).

fun <C : Any> send(request: CommandRequest<C>): CommandResult

Sends request and answers once it is accepted (CommandClient.send).

fun send(command: Any, id: String? = null): CommandResult

Sends command to the aggregate id names and answers once it is accepted.

fun <C : Any> sendAndWait(request: CommandRequest<C>): CommandResult

Sends request and answers with the result its wait plan ends with (CommandClient.wait).

fun sendAndWait(command: Any, id: String? = null): CommandResult

Sends command to the aggregate id names and answers with the result the default wait plan ends with.

sendAndWaitAsync

fun <C : Any> sendAndWaitAsync(request: CommandRequest<C>): CompletableFuture<CommandResult>

fun sendAndWaitAsync(command: Any, id: String? = null): CompletableFuture<CommandResult>

sendAndWait, asynchronously.

fun <C : Any> sendAsync(request: CommandRequest<C>): CompletableFuture<CommandResult>

fun sendAsync(command: Any, id: String? = null): CompletableFuture<CommandResult>

send, asynchronously.

fun <C : Any> stream(request: CommandRequest<C>): Stream<CommandResult>

The results of request's wait, one per hop (CommandClient.stream), sent as the stream is made; close it (try-with-resources) to stop reading early.