MessageQueue
A common interface to multiple message queues libraries.
Installation
Add this line to your application's Gemfile:
gem 'message_queue'
And then execute:
$ bundle
Or install it yourself as:
$ gem install message_queue
Usage
MessageQueue.with_connection(:adapter => :bunny, :serializer => :message_pack) do |conn|
publisher = conn.new_publisher(
:exchange => {
:name => "time",
:type => :topic
},
:message => {
:routing_key => "time.now"
}
)
consumer = conn.new_consumer(
:queue => {
:name => "print_time_now"
},
:exchange => {
:name => "time",
:routing_key => "time.#"
}
)
consumer.subscribe do |delivery_info, , payload|
puts "Received message: #{payload}"
end
publisher.publish Time.now.to_s
sleep 1
end
Examples
See examples.
Contributing
- Fork it
- Create your feature branch (
git checkout -b my-new-feature
) - Commit your changes (
git commit -am 'Add some feature'
) - Push to the branch (
git push origin my-new-feature
) - Create new Pull Request