RetryableMessageProcessor

constructor(topology: QueueTopology, queueName: String)