1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
require 'json' class Poke include Sneakers::Worker from_queue "worker.poke" def work(json) attributes = JSON.parse(json) disposition = Disposition.find_or_create_by(fingerprint: attributes["fingerprint"]) disposition.state = attributes["state"] disposition.save! ack! end end