Contents

# frozen_string_literal: true

class HelloSubscriber
  include Cloudenvoy::Subscriber

  cloudenvoy_options topic: '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

10 entries across 7 versions & 1 rubygems

Version	Path
cloudenvoy-0.5.0	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.5.0	examples/sinatra/app/subscribers/hello_subscriber.rb
cloudenvoy-0.5.rc1	examples/sinatra/app/subscribers/hello_subscriber.rb
cloudenvoy-0.5.rc1	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.4.2	examples/sinatra/app/subscribers/hello_subscriber.rb
cloudenvoy-0.4.2	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.4.1	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.4.0	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.3.1	examples/rails/app/subscribers/hello_subscriber.rb
cloudenvoy-0.3.0	examples/rails/app/subscribers/hello_subscriber.rb