Contents

# frozen_string_literal: true

class HelloSubscriber
  include Cloudenvoy::Subscriber

  cloudenvoy_options topics: ['hello-msgs']

  #
  # Process a pub/sub message
  #
  # @param [Cloudenvoy::Message] message The message to process.
  #
  def process(message)
    logger.info("Received message #{message.payload.dig('content')}")
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cloudenvoy-0.2.0	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.1.0	examples/rails/app/subscribers/hello_subscriber.rb