Class: Rabbit::Receiving::Message
- Inherits:
-
Object
- Object
- Rabbit::Receiving::Message
- Includes:
- Tainbox
- Defined in:
- lib/rabbit/receiving/message.rb
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.build(message, arguments) ⇒ Object
19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/rabbit/receiving/message.rb', line 19 def self.build(, arguments) group_id, project_id = arguments.fetch(:app_id).split(".") new( group_id: group_id, project_id: project_id, event: arguments.fetch(:type), data: , message_id: arguments.fetch(:message_id, nil), arguments: arguments, ) end |
Instance Method Details
#data=(value) ⇒ Object
32 33 34 35 36 37 |
# File 'lib/rabbit/receiving/message.rb', line 32 def data=(value) self. = value super(JSON.parse(value).deep_symbolize_keys) rescue JSON::ParserError => error mark_as_malformed!("JSON::ParserError: #{error.}") end |
#mark_as_malformed!(errors = "Error not specified") ⇒ Object
39 40 41 |
# File 'lib/rabbit/receiving/message.rb', line 39 def mark_as_malformed!(errors = "Error not specified") MalformedMessage.raise!(self, errors, caller(1)) end |