Class: RabbitmqClient::PublisherJob

Inherits:
Object
  • Object
show all
Includes:
SuckerPunch::Job
Defined in:
lib/rabbitmq_client/publisher_job.rb

Overview

Publisher class is responsible for publishing events to rabbitmq exhanges

Instance Method Summary collapse

Instance Method Details

#perform(registry, session_pool, data, options) ⇒ Object



11
12
13
14
15
16
# File 'lib/rabbitmq_client/publisher_job.rb', line 11

def perform(registry, session_pool, data, options)
  handle_publish_event(registry, session_pool, data, options)
rescue StandardError => e
  notify('network_error', error: e, options: options)
  raise
end