module Emque::Consuming::Consumer::Common
Public Class Methods
included(descendant)
click to toggle source
# File lib/emque/consuming/consumer/common.rb, line 16 def self.included(descendant) descendant.class_eval do attr_reader :message end end
Public Instance Methods
consume(handler_method, message)
click to toggle source
# File lib/emque/consuming/consumer/common.rb, line 22 def consume(handler_method, message) send(handler_method, message) end
pipe_config()
click to toggle source
# File lib/emque/consuming/consumer/common.rb, line 26 def pipe_config @pipe_config ||= Pipe::Config.new( :stop_on => ->(msg, _, _) { !(msg.respond_to?(:continue?) && msg.continue?) } ) end