messaging-rabbitmq/dev.kaccelero.commons.messaging/MessagingService

MessagingService

open class MessagingService(val exchange: String, val host: String, val username: String, val password: String, val handleMessagingUseCase: IHandleMessagingUseCase, val keys: List<<Error class: unknown class>>, val json: <Error class: unknown class>? = null, val listen: Boolean = true, val persistent: Boolean = false, val quorum: Boolean = false, val dead: Boolean = false, val maxXDeathCount: Int = 1, val coroutineScope: <Error class: unknown class> = CoroutineScope(Dispatchers.IO)) : IMessagingService

Inheritors

DelayedMessagingService

Constructors

MessagingService

constructor(exchange: String, host: String, username: String, password: String, handleMessagingUseCase: IHandleMessagingUseCase, keys: List<<Error class: unknown class>>, json: <Error class: unknown class>? = null, listen: Boolean = true, persistent: Boolean = false, quorum: Boolean = false, dead: Boolean = false, maxXDeathCount: Int = 1, coroutineScope: <Error class: unknown class> = CoroutineScope(Dispatchers.IO))

Properties

channel

open var channel: <Error class: unknown class>?

connection

open var connection: <Error class: unknown class>?

coroutineScope

open val coroutineScope: <Error class: unknown class>

dead

open val dead: Boolean = false

exchange

open val exchange: String

handleMessagingUseCase

open val handleMessagingUseCase: IHandleMessagingUseCase

host

open val host: String

json

open val json: <Error class: unknown class>? = null

keys

open val keys: List<<Error class: unknown class>>

listen

open val listen: Boolean = true

maxXDeathCount

open val maxXDeathCount: Int = 1

password

open val password: String

persistent

open val persistent: Boolean = false

quorum

open val quorum: Boolean = false

sharedQueue

open val sharedQueue: String

username

open val username: String

Functions

connect

open fun connect()

exchangeDeclare

open fun exchangeDeclare(name: String, type: String = BuiltinExchangeType.DIRECT.type, arguments: Map<String, Any> = mapOf())

handleException

open suspend fun handleException(delivery: <Error class: unknown class>, exception: <Error class: unknown class>)

handleFailedMessage

open suspend fun handleFailedMessage(delivery: <Error class: unknown class>, exception: <Error class: unknown class>)

listen

open suspend override fun listen()

publish

inline suspend fun <T> publish(routingKey: <Error class: unknown class>, value: T, persistent: Boolean = false, attempts: Int = 3, delay: Long = 5000)

queueBind

open fun queueBind(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any> = mapOf())

queueDeclare

open fun queueDeclare(name: String, exchange: String? = null, durable: Boolean = true, exclusive: Boolean = false, autoDelete: Boolean = false, arguments: Map<String, Any> = mapOf())

reconnect

open fun reconnect()

routingKey

open fun routingKey(key: String): <Error class: unknown class>

setup

open fun setup()

tryWithAttempts

open suspend fun tryWithAttempts(attempts: Int = 3, delay: Long = 5000, block: () -> Unit)