Class: FailedEventDelayedRetryWorker

Inherits:

Object

Object
FailedEventDelayedRetryWorker

show all

Includes:: Sidekiq::Worker

Defined in:: lib/failed_event_delayed_retry_worker.rb

Instance Method Summary collapse

#perform(topic, message) ⇒ Object

Instance Method Details

#perform(topic, message) ⇒ `Object`



6
7
8

# File 'lib/failed_event_delayed_retry_worker.rb', line 6

def perform(topic, message)
  KafkaProducer.new.publish_to_topic(topic, message)
end