module Emque::Producing::Message::ClassMethods

Public Instance Methods

ignored_exceptions(*ignored_exceptions) click to toggle source
# File lib/emque/producing/message/message.rb, line 43
def ignored_exceptions(*ignored_exceptions)
  @ignored_exceptions = ignored_exceptions
end
message_type(name) click to toggle source
# File lib/emque/producing/message/message.rb, line 19
def message_type(name)
  @message_type = name
end
middleware() click to toggle source
# File lib/emque/producing/message/message.rb, line 23
def middleware
  @middleware || []
end
private_attribute(name, coercion=nil, opts={}) click to toggle source
# File lib/emque/producing/message/message.rb, line 51
def private_attribute(name, coercion=nil, opts={})
  @private_attrs ||= []
  @private_attrs << name
  attribute(name, coercion, opts)
end
private_attrs() click to toggle source
# File lib/emque/producing/message/message.rb, line 57
def private_attrs
  Array(@private_attrs)
end
raise_on_failure(name) click to toggle source
# File lib/emque/producing/message/message.rb, line 31
def raise_on_failure(name)
  @raise_on_failure = name
end
read_ignored_exceptions() click to toggle source
# File lib/emque/producing/message/message.rb, line 47
def read_ignored_exceptions
  (Array(@ignored_exceptions) + Emque::Producing.configuration.ignored_exceptions).uniq
end
read_message_type() click to toggle source
# File lib/emque/producing/message/message.rb, line 27
def read_message_type
  @message_type
end
read_raise_on_failure() click to toggle source
# File lib/emque/producing/message/message.rb, line 35
def read_raise_on_failure
  if @raise_on_failure.nil?
    true
  else
    @raise_on_failure
  end
end
read_topic() click to toggle source
# File lib/emque/producing/message/message.rb, line 15
def read_topic
  @topic
end
topic(name) click to toggle source
# File lib/emque/producing/message/message.rb, line 11
def topic(name)
  @topic = name
end
use(callable) click to toggle source
# File lib/emque/producing/message/message.rb, line 61
def use(callable)
  unless callable.respond_to?(:call) and callable.arity == 1
    raise(
      ConfigurationError,
      "#{self.class.name}#use must receive a callable object with an " +
      "arity of one."
    )
  end

  @middleware ||= []
  @middleware << callable
end