Sha256: 10cb7d8e717f375194a156fdd9fb599f9c4645ad6017db151c968cc23ae3d104
Contents?: true
Size: 555 Bytes
Versions: 36
Compression:
Stored size: 555 Bytes
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
36 entries across 36 versions & 1 rubygems