Contents

require "baton"
require "bunny"
require "json"

module Baton
  class API

    # Public: Method that publishes a message using Bunny to an exchange.
    #
    # message - a json object containing the message
    # key - the routing key used to forward the message to the right queue(s)
    #
    # Examples
    #
    #   publish("{\"message\":\"a message\",\"type\":\"a type\"}", "server.production")
    #
    # Returns nothing.
    def self.publish(message, key)
      b = Bunny.new(Baton.configuration.connection_opts)
      b.start
      e = b.exchange(Baton.configuration.exchange, :auto_delete => false)
      e.publish(message, :key => key, :mandatory => true)
      b.stop
    end

  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version	Path
baton-0.7.0	lib/baton/api.rb
baton-0.6.0	lib/baton/api.rb
baton-0.5.6	lib/baton/api.rb
baton-0.5.5	lib/baton/api.rb
baton-0.5.4	lib/baton/api.rb
baton-0.5.2	lib/baton/api.rb
baton-0.4.10	lib/baton/api.rb
baton-0.4.9	lib/baton/api.rb
baton-0.4.8	lib/baton/api.rb
baton-0.4.5	lib/baton/api.rb
baton-0.4.4	lib/baton/api.rb
baton-0.4.3	lib/baton/api.rb
baton-0.4.2	lib/baton/api.rb
baton-0.4.1	lib/baton/api.rb
baton-0.3.7	lib/baton/api.rb
baton-0.3.6	lib/baton/api.rb