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
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