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

RabbitMqServer

open class RabbitMqServer : QueueServer

Constructors

private constructor(builder: RabbitMqServer.Builder)

Types

open class Builder : QueueServer.AbstractBuilder<RabbitMqServer.Builder>

Properties

private open var channel: Channel

componentProvider

protected val componentProvider: ComponentProvider

private open var connection: Connection

private val connector: RabbitMqConnector

private val initialized: AtomicBoolean

protected val log: Logger

networkRecoveryInterval

private val networkRecoveryInterval: Int

protected val nodes: Set<HostPort>

protected val password: String

val queuePublisher: QueuePublisher

private val running: AtomicBoolean

serializerRegistry

protected val serializerRegistry: SerializerRegistry<MessageSerializer>

private open var taskExecutor: TaskExecutor

protected val username: String

private val virtualHost: String

Functions

open fun builder(): RabbitMqServer.Builder

fun close()

getSerializerRegistry

open fun getSerializerRegistry(): SerializerRegistry<MessageSerializer>

protected open fun onPublish(exchange: String, routingKey: String, body: Array<Byte>)

onQueueServerStart

protected fun onQueueServerStart()

onRegisterListener

protected open fun onRegisterListener(listener: QueueListener<out Any>)

protected abstract fun onStart()

protected fun onStart()

protected fun onStop()

processDelivery

open fun <T> processDelivery(listener: QueueListener<T>, body: Array<Byte>)

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException