NSL Queue/xyz.noisif.nsl.queue.retryable/RetryableMessageProcessor

RetryableMessageProcessor

open class RetryableMessageProcessor : MessageProcessor

Constructors

RetryableMessageProcessor

constructor(topology: QueueTopology, queueName: String)

Properties

private val LOG: Logger

private val queueName: String

private val topology: QueueTopology

Functions

open fun process(task: RunnableWithException, acknowledgment: MessageAcknowledgment)