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

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