Package-level declarations

Types

Link copied to clipboard
open class DelayedMessagingService(val host: String, val user: String, val password: String, val exchange: IMessagingExchange, val queue: IMessagingQueue, val keys: List<IMessagingKey>, val handleMessagingUseCaseFactory: () -> IHandleMessagingUseCase, val coroutineScope: CoroutineScope, val json: Json? = null, val autoConnect: Boolean = true, val autoListen: Boolean = true, val persistent: Boolean = false, val quorum: Boolean = false, val dead: Boolean = false, val prefetchCount: UShort, val maxXDeathCount: Int = 1, val connectionName: String = queue.queue) : MessagingService

A messaging service that supports delayed message delivery using the x-delayed-message exchange type.

Link copied to clipboard

Interface defining the contract for a messaging service.

Link copied to clipboard
open class MessagingService(val host: String, val user: String, val password: String, val exchange: IMessagingExchange, val queue: IMessagingQueue, val keys: List<IMessagingKey>, val handleMessagingUseCaseFactory: () -> IHandleMessagingUseCase, val coroutineScope: CoroutineScope, val json: Json? = null, val autoConnect: Boolean = true, val autoListen: Boolean = true, val persistent: Boolean = false, val quorum: Boolean = false, val dead: Boolean = false, val prefetchCount: UShort, val maxXDeathCount: Int = 1, val connectionName: String = queue.queue) : IMessagingService

A robust messaging service that handles connection, setup, publishing, and listening for messages.

Functions

Link copied to clipboard
suspend fun mapOfRequestId(): Map<String, Field.LongString>

Retrieves the current request ID from the coroutine context, if available.

Link copied to clipboard
inline suspend fun <T> tryWithAttempts(attempts: Int = 3, delay: Long = 5000, block: () -> T): T

Attempts to execute a block of code with retries and a delay between attempts.

Link copied to clipboard
suspend fun withCallId(delivery: AMQPResponse.Channel.Message.Delivery, block: suspend () -> Unit)

Executes a block of code with a specified call ID in the coroutine context, if the call ID is present.