Contents

#
# Poller that consume internal AWS Events,
# like S3 notifications, CloudWatch events, etc.
#
# This poller's output message will be a list of hashes,
# each containing one event.
#
module Pheme
  module MessageType
    module AwsEvent
      extend ActiveSupport::Concern

      def get_content(body)
        body['Records']
      end

      def format
        :aws_event
      end

      def parse_aws_event(message_contents)
        RecursiveOpenStruct.new({wrapper: message_contents}, recurse_over_arrays: true).wrapper
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pheme-0.0.8	lib/pheme/message_type/aws_event.rb