Contents

module Shoryuken
  class Topic
    def initialize(name, sns)
      @name, @sns = name, sns
    end

    def arn
      @arn ||= Client.sns_arn.new(@name).to_s
    end

    def send_message(body, options = {})
      body = JSON.dump(body) if body.is_a?(Hash)

      @sns.publish(topic_arn: arn, message: body)
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
shoryuken-2.1.3	lib/shoryuken/topic.rb
shoryuken-2.1.2	lib/shoryuken/topic.rb
shoryuken-2.1.1	lib/shoryuken/topic.rb
shoryuken-2.1.0	lib/shoryuken/topic.rb
shoryuken-2.0.11	lib/shoryuken/topic.rb
shoryuken-2.0.4	lib/shoryuken/topic.rb
shoryuken-2.0.3	lib/shoryuken/topic.rb
shoryuken-2.0.2	lib/shoryuken/topic.rb
shoryuken-2.0.1	lib/shoryuken/topic.rb
shoryuken-2.0.0	lib/shoryuken/topic.rb
shoryuken-1.0.3	lib/shoryuken/topic.rb
shoryuken-1.0.2	lib/shoryuken/topic.rb
shoryuken-1.0.1	lib/shoryuken/topic.rb
shoryuken-1.0.0	lib/shoryuken/topic.rb