class Hutch::Adapters::MarchHareAdapter
Constants
- ConnectionRefused
- DEFAULT_VHOST
- PreconditionFailed
Public Class Methods
decode_message(delivery_info, payload)
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 20 def self.decode_message(delivery_info, payload) [delivery_info, delivery_info.properties, payload] end
new(opts = {})
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 16 def initialize(opts = {}) @connection = MarchHare.connect(opts) end
new_exchange(ch, exchange_type, exchange_name, exchange_options)
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 36 def self.new_exchange(ch, exchange_type, exchange_name, exchange_options) MarchHare::Exchange.new(ch, exchange_name, exchange_options.merge(type: exchange_type)) end
Public Instance Methods
create_channel(n = nil, consumer_pool_size = 1, consumer_pool_abort_on_exception = false)
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 28 def create_channel(n = nil, consumer_pool_size = 1, consumer_pool_abort_on_exception = false) @connection.create_channel(n) end
current_timestamp()
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 32 def current_timestamp Time.now end
prefetch_channel(ch, prefetch)
click to toggle source
# File lib/hutch/adapters/march_hare.rb, line 24 def prefetch_channel(ch, prefetch) ch.prefetch = prefetch if prefetch end