require 'hat/middlewares/worker/json' module Examples class Subscriber < Hat::Worker include Hat::Middlewares::Worker::JSON queue 'hat.examples.subscriber' def perform(delivery_info, properties, payload) logger.info payload end end end