Class: HotBunnies::Queue::CallbackConsumer
- Inherits:
-
BaseConsumer
- Object
- DefaultConsumer
- BaseConsumer
- HotBunnies::Queue::CallbackConsumer
- Defined in:
- lib/hot_bunnies/queue.rb
Direct Known Subclasses
Instance Method Summary collapse
- #callback(headers, message) ⇒ Object
-
#initialize(channel, callback) ⇒ CallbackConsumer
constructor
A new instance of CallbackConsumer.
Methods inherited from BaseConsumer
#cancel, #deliver, #handleCancel, #handleCancelOk, #handleDelivery, #start
Constructor Details
#initialize(channel, callback) ⇒ CallbackConsumer
Returns a new instance of CallbackConsumer.
185 186 187 188 189 190 191 |
# File 'lib/hot_bunnies/queue.rb', line 185 def initialize(channel, callback) super(channel) @callback = callback @callback_arity = @callback.arity @cancelled = false @cancelling = false end |
Instance Method Details
#callback(headers, message) ⇒ Object
193 194 195 196 197 198 199 |
# File 'lib/hot_bunnies/queue.rb', line 193 def callback(headers, ) if @callback_arity == 2 @callback.call(headers, ) else @callback.call() end end |