Class: Clamour::Message::Receive

Inherits:

Object

• Object
• Clamour::Message::Receive

Includes:

Handler

Defined in:

lib/clamour/message/receive.rb

Overview

Unpack message and reroute it using the same Subscription.

Class Method Summary

• .perform(wired, subscription) ⇒ Object

Methods included from Handler

#on_message, #perform

Class Method Details

.perform(wired, subscription) ⇒ Object

Parameters:

• wired (Clamour::Message::Sent)
• subscription (Clamour::Subscription)

# File 'lib/clamour/message/receive.rb', line 10

def self.perform(wired, subscription)
  attributes = ActiveSupport::HashWithIndifferentAccess.new(wired.payload)
  type = attributes[:_type]
  subscription.route(type, attributes)
end