Class: Queight::Exchange

Inherits:
Object
  • Object
show all
Defined in:
lib/queight/exchange.rb

Direct Known Subclasses

DefaultExchange

Instance Method Summary collapse

Constructor Details

#initialize(type, name, message_options = {}) ⇒ Exchange

Returns a new instance of Exchange.



3
4
5
6
7
8
9
10
 
# File 'lib/queight/exchange.rb', line 3

def initialize(type, name, message_options = {})
  @type = type
  @name = name
  @message_options = {
    :content_type => "application/json",
    :persistent => true,
  }.merge(message_options)
end

Instance Method Details

#bind(channel, queue) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/queight/exchange.rb', line 24

def bind(channel, queue)
  if queue.routing_patterns.any?
    queue.routing_patterns.each do |routing_pattern|
      queue.queue(channel).bind(
        exchange(channel),
        :routing_key => routing_pattern
      )
    end
  else
    queue.queue(channel).bind(exchange(channel))
  end
end

#delete(channel) ⇒ Object 



20
21
22
 
# File 'lib/queight/exchange.rb', line 20

def delete(channel)
  channel.exchange(@name, exchange_options).delete
end

#exchange(channel) ⇒ Object 



16
17
18
 
# File 'lib/queight/exchange.rb', line 16

def exchange(channel)
  channel.exchange(@name, exchange_options)
end

#publish(channel, message, routing_key) ⇒ Object 



12
13
14
 
# File 'lib/queight/exchange.rb', line 12

def publish(channel, message, routing_key)
  exchange(channel).publish(message, message_options_for(routing_key))
end