gistfile1.rb

# omitted

client = Stomp::Client.new(config.queue.user,
                           config.queue.pass,
                           config.queue.host,
                           config.queue.port,
                           true
                          )   

client.subscribe(config.queue.name, :ack => 'client') do |msg|  

  begin
    data = JSON.parse(msg.body)
    DaemonKit.logger.info "Processing #{data['update_type']} for #{data['hotel_code']} from #{data['timestamp']}}"
    save_update(data)
    DaemonKit.logger.info "Update processed"
    client.acknowledge(msg)
    DaemonKit.logger.info "Acknowledged"
  rescue Exception => e
    # omitted
  end 

end

client.join