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