Module: Euston::RabbitMq::Queues

Included in:: HandlerBinder, RetryingSubscription

Defined in:: lib/euston-rabbitmq/euston/queues.rb

Instance Method Summary collapse

Instance Method Details

#default_queue_options ⇒ `Object`



4
5
6

# File 'lib/euston-rabbitmq/euston/queues.rb', line 4

def default_queue_options
  { :durable => true, :nowait => true }
end

#get_queue(channel, name, opts = {}) ⇒ `Object`



8
9
10

# File 'lib/euston-rabbitmq/euston/queues.rb', line 8

def get_queue channel, name, opts = {}
  channel.queue name.to_s, default_queue_options.merge(opts)
end