Method: Krakow::Connection#process_to_queue!

Defined in:
lib/krakow/connection.rb

#process_to_queue! ⇒ nil

Receive messages and place into queue

Returns:

  • (nil) 


212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
 
# File 'lib/krakow/connection.rb', line 212

def process_to_queue!
  unless(@running)
    @running = true
    while(@running)
      message = handle(receive)
      if(message)
        debug "Adding message to queue #{message}"
        queue << message
        if(notifier)
          warn "Sending new message notification: #{notifier} - #{message}"
          notifier.broadcast(message)
        end
      else
        debug 'Received `nil` message. Ignoring.'
      end
    end
  end
  nil
end