console-components/org.cryptotrader.console.library.component/ConsoleRequestGateway

ConsoleRequestGateway

@Component

class ConsoleRequestGateway @Autowired constructor(val eventPublisher: EventPublisher) : RequestGatewayController<ConsoleCommandRequest, ConsoleCommandResponse>

Constructors

@Autowired

constructor(eventPublisher: EventPublisher)

Properties

eventPublisher

open override val eventPublisher: EventPublisher

Functions

execute

open override fun execute(binding: EventBinding, request: ConsoleCommandRequest): ConsoleCommandResponse

open override fun execute(binding: EventBinding, request: ConsoleCommandRequest, timeout: Duration): ConsoleCommandResponse

open override fun execute(binding: EventBinding, request: ConsoleCommandRequest, timeout: Duration, authorizationHeader: String?): ConsoleCommandResponse

getCorrelationId

fun getCorrelationId(): String

getFutureResponse

fun getFutureResponse(): CompletableFuture<ConsoleCommandResponse>

getInitialHeaders

fun getInitialHeaders(correlationId: String, authorizationHeader: String?): Map<String, Any>

handleResponse

fun handleResponse(message: Message<ConsoleCommandResponse>)

setPendingResponse

fun setPendingResponse(correlationId: String, future: CompletableFuture<ConsoleCommandResponse>)

tryExecuteAndWait

fun tryExecuteAndWait(future: CompletableFuture<ConsoleCommandResponse>, correlationId: String, timeout: Duration): ConsoleCommandResponse