wow-apiclient/me.ahoo.wow.apiclient.command/ReactiveRestCommandGateway

ReactiveRestCommandGateway

interface ReactiveRestCommandGateway : RestCommandGateway<Mono<ResponseEntity<CommandResult>>, Mono<CommandResult>>

Functions

Link copied to clipboard
@PostExchange
abstract override fun send(sendUri: URI, @RequestHeader(value = "Command-Type", required = false) commandType: String, @RequestBody command: Any, @RequestHeader(value = "Command-Wait-Stage", required = false) waitStage: CommandStage, @RequestHeader(value = "Command-Wait-Context", required = false) waitContext: String?, @RequestHeader(value = "Command-Wait-Processor", required = false) waitProcessor: String?, @RequestHeader(value = "Command-Wait-Timout", required = false) waitTimeout: Long?, @RequestHeader(value = "Command-Tenant-Id", required = false) tenantId: String?, @RequestHeader(value = "Command-Aggregate-Id", required = false) aggregateId: String?, @RequestHeader(value = "Command-Aggregate-Version", required = false) aggregateVersion: Int?, @RequestHeader(value = "Command-Request-Id", required = false) requestId: String?, @RequestHeader(value = "Command-Local-First", required = false) localFirst: Boolean?, @RequestHeader(value = "Command-Aggregate-Context", required = false) context: String?, @RequestHeader(value = "Command-Aggregate-Name", required = false) aggregate: String?): Mono<ResponseEntity<CommandResult>>

open fun send(commandRequest: CommandRequest): Mono<CommandResult>

Send a command request.

Link copied to clipboard
open override fun unwrapResponse(commandRequest: CommandRequest, response: Mono<ResponseEntity<CommandResult>>): Mono<CommandResult>