lib/propono.rb in propono-0.2.0 vs lib/propono.rb in propono-0.3.0

- old
+ new

@@ -6,10 +6,11 @@ require "propono/components/topic" require "propono/services/post_subscriber" require "propono/services/publisher" require "propono/services/queue_creator" +require "propono/services/queue_listener" require "propono/services/queue_subscriber" require "propono/services/subscriber" require "propono/services/topic_creator" module Propono @@ -25,8 +26,12 @@ Subscriber.subscribe_by_queue(*args) end def self.subscribe_by_post(*args) Subscriber.subscribe_by_post(*args) + end + + def self.listen_to_queue(*args, &block) + QueueListener.listen(*args, &block) end end