class Hutch::Adapters::Adapter
Constants
- ConnectionRefused
- DEFAULT_VHOST
- PreconditionFailed
Public Class Methods
decode_message(delivery_info, properties, payload)
click to toggle source
# File lib/hutch/adapters/bunny.rb, line 20 def self.decode_message(delivery_info, properties, payload) [delivery_info, properties, payload] end
new(opts={})
click to toggle source
# File lib/hutch/adapters/bunny.rb, line 16 def initialize(opts={}) @connection = Bunny.new(opts) end
new_exchange(ch, exchange_type, exchange_name, exchange_options)
click to toggle source
# File lib/hutch/adapters/bunny.rb, line 32 def self.new_exchange(ch, exchange_type, exchange_name, exchange_options) Bunny::Exchange.new(ch, exchange_type, exchange_name, exchange_options) end
Public Instance Methods
current_timestamp()
click to toggle source
# File lib/hutch/adapters/bunny.rb, line 28 def current_timestamp Time.now.to_i end
prefetch_channel(ch, prefetch)
click to toggle source
# File lib/hutch/adapters/bunny.rb, line 24 def prefetch_channel(ch, prefetch) ch.prefetch(prefetch) if prefetch end