subscriber code example

subscriber_code.rb

EM.schedule do

  user_subscription = Subscriptions::User.new
  Ragnar.exchange(:topic, 'events') do |x|
    x.queue_prefix = :service_name

    x.subscribe('user.delete', &user_subscription.method(:user_delete))

    x.subscribe('user.login', &user_subscription.method(:user_login))
  end
end

module Subscriptions
  class User
    def user_delete(headers, payload)
      begin
        # do something here
      rescue
        # handle the errors
      end
    end

    def user_login(headers, payload)
      begin
        # do something here
      rescue
        #handle the errors
      end
    end
  end
end