class FakeSmith

# File lib/fake_smith.rb, line 58
def self.add_message(queue_name, message)
  messages[queue_name] ||= []
  messages[queue_name] << message
end

# File lib/fake_smith.rb, line 63
def self.clear_all
  clear_subscriptions
  clear_messages
  clear_logger
end

# File lib/fake_smith.rb, line 44
def self.define_subscription(queue_name, options, &blk)
  subscriptions[queue_name] = blk
  subscriptions_options[queue_name] = options
end

# File lib/fake_smith.rb, line 54
def self.get_messages(queue_name)
  messages[queue_name] ||= []
end

# File lib/fake_smith.rb, line 73
def self.logger
  @logger ||= FakeSmith::Logger.new
end

# File lib/fake_smith.rb, line 31
def self.reply_handlers
  @reply_handlers ||= {}
end

# File lib/fake_smith.rb, line 35
def self.send_message(queue_name, payload, receiver)
  raise "no subscribers on queue: #{queue_name}" unless subscriptions[queue_name]
  receiver = ReceiverDecorator.new(receiver)
  opts = subscriptions_options[queue_name]
  auto_ack = opts.key?(:auto_ack) ? opts[:auto_ack] : true
  receiver.ack if auto_ack
  subscriptions[queue_name].call(payload, receiver)
end

# File lib/fake_smith.rb, line 26
def self.set_reply_handler(queue_name, &blk)
  @reply_handlers ||= {}
  @reply_handlers[queue_name] = blk
end

# File lib/fake_smith.rb, line 69
def self.subscribed_queues
  subscriptions.keys
end

# File lib/fake_smith.rb, line 49
def self.undefine_subscription(queue_name, &blk)
  subscriptions.delete(queue_name)
  blk.call
end

# File lib/fake_smith.rb, line 99
def self.clear_logger
  @logger = nil
end

# File lib/fake_smith.rb, line 83
def self.clear_messages
  @messages = {}
end

# File lib/fake_smith.rb, line 95
def self.clear_subscriptions
  @subscriptions = {}
end

# File lib/fake_smith.rb, line 79
def self.messages
  @messages ||= {}
end

# File lib/fake_smith.rb, line 87
def self.subscriptions
  @subscriptions ||= {}
end

# File lib/fake_smith.rb, line 91
def self.subscriptions_options
  @subscriptions_options ||= {}
end