module Octo::Helpers::ApiConsumerHelper
Helper Module for Octo
Consumer
Public Instance Methods
call_hooks(event, *args)
click to toggle source
Set Octo
callbacks @param [String] event Event name @param [Hash] *args Points to the messsage hash
# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 43 def call_hooks(event, *args) hook = [:after, event.gsub('.', '_')].join('_').to_sym Octo::Callbacks.run_hook(hook, *args) end
handle(msg)
click to toggle source
Handles Kafka messages and perform required operations @param [Hash] msg Hash
Message
# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 26 def handle(msg) msg_obj = Octo::Message::Message.new(msg) msg = msg_obj.to_h begin eventName = msg[:event_name] if (valid_events.include?eventName) call_hooks(eventName, msg) end rescue Exception => e puts e.message puts e.backtrace.inspect end end
valid_events()
click to toggle source
Get all the valid events @return [Set<Symbol>] Valid events globally
# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 12 def valid_events Set.new(Octo.get_config(:allowed_events)) end