RabbitMqConsumer

class RabbitMqConsumer @Inject constructor(json: Json, channel: Channel) : DefaultConsumer

Constructors

@Inject

constructor(json: Json, channel: Channel)

object Companion : Logging

open fun getChannel(): Channel

open override fun handleCancel(p0: String)

open override fun handleCancelOk(p0: String)

open override fun handleConsumeOk(p0: String)

open override fun handleDelivery(consumerTag: String?, envelope: Envelope?, properties: AMQP.BasicProperties?, body: ByteArray?)

open override fun handleRecoverOk(p0: String)

open override fun handleShutdownSignal(p0: String, p1: ShutdownSignalException)