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 = CommandStage.PROCESSED, @RequestHeader(value = "Command-Wait-Context", required = false) waitContext: String? = null, @RequestHeader(value = "Command-Wait-Processor", required = false) waitProcessor: String? = null, @RequestHeader(value = "Command-Wait-Timeout", required = false) waitTimeout: Long? = null, @RequestHeader(value = "Command-Tenant-Id", required = false) tenantId: String? = null, @RequestHeader(value = "Command-Owner-Id", required = false) ownerId: String?, @RequestHeader(value = "Wow-Space-Id", required = false) spaceId: SpaceId?, @RequestHeader(value = "Command-Aggregate-Id", required = false) aggregateId: String? = null, @RequestHeader(value = "Command-Aggregate-Version", required = false) aggregateVersion: Int? = null, @RequestHeader(value = "Command-Request-Id", required = false) requestId: String? = null, @RequestHeader(value = "Command-Local-First", required = false) localFirst: Boolean? = null, @RequestHeader(value = "Command-Aggregate-Context", required = false) context: String? = null, @RequestHeader(value = "Command-Aggregate-Name", required = false) aggregate: String? = null): Mono<ResponseEntity<CommandResult>>
Link copied to clipboard
open override fun unwrapResponse(commandRequest: CommandRequest, response: Mono<ResponseEntity<CommandResult>>): Mono<CommandResult>
Generated by Dokka
© 2026 Copyright