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