Module: FeatureChannel::Subscriber

Defined in:
lib/feature_channel/subscriber.rb,
lib/feature_channel/subscriber/message_processor.rb

Defined Under Namespace

Classes: MessageProcessor

Class Method Summary collapse

Class Method Details

.process(topic, message) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/feature_channel/subscriber.rb', line 9

def process(topic, message)
  payload = message_decode(message)
  model = feature_model(payload['feature'])

  return unless accept_message? model

  processor =
    Subscriber::MessageProcessor.new(message: payload, model: model)

  processor.run!
end