Sha256: e9b8b289917a713b1e5ca2eb7a67cb0e2c7c87049344ded367f834227b979758
Contents?: true
Size: 1002 Bytes
Versions: 30
Compression:
Stored size: 1002 Bytes
Contents
# This is a basic implementation of the Notification service using Amazon SNS.
# The expected usage is as follows :
# notification_service = DispatchRider::NotificationServices::AwsSns.new
# notification_service.publish(:to => [:foo, :oof], :message => {:subject => "bar", :body => "baz"})
module DispatchRider
module NotificationServices
class AwsSns < Base
def notifier_builder
AWS::SNS
rescue NameError
raise AdapterNotFoundError.new(self.class.name, 'aws-sdk')
end
def channel_registrar_builder
Registrars::SnsChannel
end
# not really happy with this, but the notification service registrar system is way too rigid to do this cleaner
# since you only can have one notifier for the whole service, but you need to create a new one for each region
def channel(name)
arn = self.fetch(name)
region = arn.split(':')[3]
notifier_builder.new(region: region).topics[arn]
end
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems