Class: Smith::Messaging::Receiver

Inherits:
Object
  • Object
show all
Defined in:
lib/fake_smith.rb

Instance Method Summary collapse

Constructor Details

#initialize(queue_name, options = {}) ⇒ Receiver

Returns a new instance of Receiver.



129
130
131
132
 
# File 'lib/fake_smith.rb', line 129

def initialize(queue_name, options = {})
  @queue_name = queue_name
  @options = options
end

Instance Method Details

#on_requeue_limit(&blk) ⇒ Object 



146
147
148
 
# File 'lib/fake_smith.rb', line 146

def on_requeue_limit(&blk)
  @on_requeue_limit = blk
end

#requeue_parameters(opts) ⇒ Object 



142
143
144
 
# File 'lib/fake_smith.rb', line 142

def requeue_parameters(opts)
  @requeue_opts = opts
end

#subscribe(&blk) ⇒ Object 



134
135
136
 
# File 'lib/fake_smith.rb', line 134

def subscribe(&blk)
  FakeSmith.define_subscription(@queue_name, @options, &blk)
end

#unsubscribe(&blk) ⇒ Object 



138
139
140
 
# File 'lib/fake_smith.rb', line 138

def unsubscribe(&blk)
  FakeSmith.undefine_subscription(@queue_name, &blk)
end