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