class Smith::Messaging::Receiver
Public Class Methods
new(queue_name, options = {})
click to toggle source
# File lib/fake_smith.rb, line 129 def initialize(queue_name, options = {}) @queue_name = queue_name @options = options end
Public Instance Methods
on_requeue_limit(&blk)
click to toggle source
# File lib/fake_smith.rb, line 146 def on_requeue_limit(&blk) @on_requeue_limit = blk end
requeue_parameters(opts)
click to toggle source
# File lib/fake_smith.rb, line 142 def requeue_parameters(opts) @requeue_opts = opts end
subscribe(&blk)
click to toggle source
# File lib/fake_smith.rb, line 134 def subscribe(&blk) FakeSmith.define_subscription(@queue_name, @options, &blk) end
unsubscribe(&blk)
click to toggle source
# File lib/fake_smith.rb, line 138 def unsubscribe(&blk) FakeSmith.undefine_subscription(@queue_name, &blk) end