Class: SharedBroker::DLQ::Redriver

Inherits:

Object

• Object
• SharedBroker::DLQ::Redriver

Defined in:

lib/shared_broker/dlq/redriver.rb

Class Method Summary

• .redrive(client, dlq_name, original_topic, limit: nil) ⇒ Object

Class Method Details

.redrive(client, dlq_name, original_topic, limit: nil) ⇒ Object

# File 'lib/shared_broker/dlq/redriver.rb', line 6

def self.redrive(client, dlq_name, original_topic, limit: nil)
  adapter = client.send(:resolve_adapter, original_topic)
  adapter.redrive_dlq(dlq_name, original_topic, limit: limit)
end