Class: Artsy::EventService::Publisher

Inherits:
Object
  • Object
show all
Defined in:
lib/artsy-eventservice/artsy/event_service/publisher.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.publish(topic:, event:, routing_key: nil) ⇒ Object 



5
6
7
 
# File 'lib/artsy-eventservice/artsy/event_service/publisher.rb', line 5

def self.publish(topic:, event:, routing_key: nil)
  new.post_event(topic: topic, event: event, routing_key: routing_key)
end

Instance Method Details

#config ⇒ Object 



25
26
27
 
# File 'lib/artsy-eventservice/artsy/event_service/publisher.rb', line 25

def config
  Artsy::EventService.config
end

#post_event(topic:, event:, routing_key: nil) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/artsy-eventservice/artsy/event_service/publisher.rb', line 9

def post_event(topic:, event:, routing_key: nil)
  raise 'Event missing topic or verb.' if event.verb.to_s.empty? || topic.to_s.empty?
  RabbitMQConnection.get_channel do |channel|
    channel.confirm_select if config.confirms_enabled
    exchange = channel.topic(topic, durable: true)
    exchange.publish(
      event.json,
      routing_key: routing_key || event.verb,
      persistent: true,
      content_type: 'application/json',
      app_id: config.app_name
    )
    raise 'Publishing event failed' if config.confirms_enabled && !channel.wait_for_confirms
  end
end