require "sarcastic_bunny/version"

module SarcasticBunny
  def self.clear!
    @published_messages = []
  end

  def self.published_messages
    @published_messages ||= []
  end

  def self.publish_message(channel, payload, exchange, routing_key, opts)
    @published_messages ||= []
    @published_messages << { channel: channel, payload: payload, exchange: exchange, routing_key: routing_key, opts: opts }
  end
end

require 'sarcastic_bunny/bunny_ext/channel'
require 'sarcastic_bunny/bunny_ext/exchange'
require 'sarcastic_bunny/bunny_ext/session'