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