Contents

# frozen_string_literal: true

class HelloPublisher
  include Cloudenvoy::Publisher

  cloudenvoy_options topic: 'hello-msgs'

  #
  # Set message metadata (attributes)
  #
  # @param [String] msg The message to publish
  #
  # @return [Hash] The message metadata
  #
  def metadata(msg)
    {
      kind: msg.start_with?('Hello') ? 'hello' : 'regular'
    }
  end

  #
  # Format the payload.
  #
  # @param [String] msg The message to publish
  #
  # @return [Hash] The formatted message
  #
  def payload(msg)
    {
      type: 'message',
      content: msg
    }
  end
end

Version data entries

16 entries across 11 versions & 1 rubygems

Version	Path
cloudenvoy-0.6.0	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.6.0	examples/sinatra/app/publishers/hello_publisher.rb
cloudenvoy-0.6.rc1	examples/sinatra/app/publishers/hello_publisher.rb
cloudenvoy-0.6.rc1	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.5.0	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.5.0	examples/sinatra/app/publishers/hello_publisher.rb
cloudenvoy-0.5.rc1	examples/sinatra/app/publishers/hello_publisher.rb
cloudenvoy-0.5.rc1	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.4.2	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.4.2	examples/sinatra/app/publishers/hello_publisher.rb
cloudenvoy-0.4.1	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.4.0	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.3.1	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.3.0	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.2.0	examples/rails/app/publishers/hello_publisher.rb
cloudenvoy-0.1.0	examples/rails/app/publishers/hello_publisher.rb