Contents

module BunnyCarrot
  class BusinessActor < LoggingActor

    def initialize
      super()
      logger.info 'Business actor initialized'
    end

    def act(message_hash)
      payload = message_hash.fetch(:payload)
      worker  = message_hash.fetch(:worker)
      headers = message_hash.fetch(:message_headers)
      logger.info "Business #{self.object_id} is acting: #{payload.inspect}"
      worker.run(payload, headers)
      true
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bunny_carrot-0.0.2	lib/bunny_carrot/business_actor.rb