Contents

require_relative "../lib/message_queue"

MessageQueue.with_connection(:adapter => :bunny, :serializer => :message_pack) do |conn|
  publisher = conn.new_publisher(
    :exchange => {
      :name => "time",
      :type => :topic
    },
    :message => {
      :routing_key => "time.now"
    }
  )

  publisher.publish Time.now.to_s
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
message_queue-0.0.4	examples/publisher.rb
message_queue-0.0.3	examples/publisher.rb
message_queue-0.0.2	examples/publisher.rb