NSL Queue/xyz.noisif.nsl.queue.rabbitmq/RabbitMqDeliverCallback

RabbitMqDeliverCallback

open class RabbitMqDeliverCallback : DeliverCallback

Constructors

RabbitMqDeliverCallback

constructor(messageProcessor: MessageProcessor, messageHandler: MessageHandler, listener: QueueListener<out Any>, channel: Channel)

Properties

private val channel: Channel

private val listener: QueueListener<out Any>

private val messageHandler: MessageHandler

messageProcessor

private val messageProcessor: MessageProcessor

Functions

open fun handle(consumerTag: String, message: Delivery)