Sha256: 9e9605343b66de4e4b5e489dc0b7076fb59136696f29981b911837d531cd3504
Contents?: true
Size: 535 Bytes
Versions: 47
Compression:
Stored size: 535 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)
ResourceStruct::FlexStruct.new({ wrapper: message_contents }).wrapper
end
end
end
end
Version data entries
47 entries across 47 versions & 1 rubygems