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