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.



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

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

Instance Method Details

#on_requeue_limit(&blk) ⇒ Object 



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

def on_requeue_limit(&blk)
  @on_requeue_limit = blk
end

#requeue_parameters(opts) ⇒ Object 



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

def requeue_parameters(opts)
  @requeue_opts = opts
end

#subscribe(&blk) ⇒ Object 



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

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

#unsubscribe(&blk) ⇒ Object 



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

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