module QueueingRabbit::JobExtensions::DirectExchange::ClassMethods

Public Instance Methods

binding_declarations() click to toggle source
# File lib/queueing_rabbit/extensions/direct_exchange.rb, line 17
def binding_declarations
  @binding_declarations ||= []
  @binding_declarations + [:routing_key => queue_name.to_s]
end
exchange_options() click to toggle source
# File lib/queueing_rabbit/extensions/direct_exchange.rb, line 12
def exchange_options
  @exchange_options ||= {}
  @exchange_options.merge(:type => :direct)
end