exchangeDeclare

abstract suspend fun exchangeDeclare(exchange: IMessagingExchange, type: String = BuiltinExchangeType.DIRECT, arguments: Map<String, Field> = mapOf())

Declares an exchange with the specified parameters.

Parameters

exchange

The exchange to declare.

type

The type of the exchange (default is DIRECT).

arguments

Additional arguments for the exchange.