NSL Queue/xyz.noisif.nsl.queue/QueueServer

QueueServer

abstract class QueueServer : IdempotentService, MessageHandler

Inheritors

Constructors

protected constructor(builder: QueueServer.AbstractBuilder<out Any>)

Types

AbstractBuilder

protected abstract class AbstractBuilder<B : QueueServer.AbstractBuilder<B>?>

Properties

componentProvider

protected val componentProvider: ComponentProvider

private val initialized: AtomicBoolean

protected val log: Logger

protected val nodes: Set<HostPort>

protected val password: String

val queuePublisher: QueuePublisher

private val running: AtomicBoolean

serializerRegistry

protected val serializerRegistry: SerializerRegistry<MessageSerializer>

protected val username: String

Functions

fun close()

getSerializerRegistry

open fun getSerializerRegistry(): SerializerRegistry<MessageSerializer>

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

onQueueServerStart

protected abstract fun onQueueServerStart()

onRegisterListener

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

protected fun onStart()

protected abstract fun onStop()

processDelivery

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

registerListeners

private open fun registerListeners(listeners: Set<QueueListener<out Any>>)

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException