QueuePublisher

Constructors

constructor(queueServer: QueueServer)

private val LOG: Logger

open fun <T> publish(exchange: String, routingKey: String, payload: T)

open fun <T> publish(exchange: String, routingKey: String, payload: T, format: SerializerFormat)

open fun <T> publishToQueue(queueName: String, payload: T)

open fun <T> publishToQueue(queueName: String, payload: T, format: SerializerFormat)