CommandRelay

Writes the commands admitted on a node to a command topic instead of executing them there: the topic router's or a peer context's. The target's intake executes them.

Properties

Link copied to clipboard
abstract val topic: String

The command topic, as a failure names it.

Functions

Link copied to clipboard
abstract suspend fun send(command: Command<*>, wait: WaitContext?)

Writes command with wait and the trace it is sent in, and waits for the broker; throws when it did not ack.