Class: Messaging::BaseHandler Deprecated

Inherits:
Object
  • Object
show all
Defined in:
lib/messaging/base_handler.rb

Overview

Deprecated.

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.allowed_message?(message_class) ⇒ Boolean

Returns:

  • (Boolean) 


36
37
38
39
40
 
# File 'lib/messaging/base_handler.rb', line 36

def allowed_message?(message_class)
  return true if only_messages.empty?

  only_messages.include? message_class
end

.call(message) ⇒ Object 



23
24
25
26
27
 
# File 'lib/messaging/base_handler.rb', line 23

def call(message)
  return unless allowed_message?(message.class)

  new.on_message(message, nil)
end

.default_group_id ⇒ Object 



19
20
21
 
# File 'lib/messaging/base_handler.rb', line 19

def default_group_id
  Config.app_name + '-' + name.underscore
end

.group_id(group_id = nil) ⇒ Object 



14
15
16
17
 
# File 'lib/messaging/base_handler.rb', line 14

def group_id(group_id = nil)
  @group_id = group_id if group_id
  @group_id || default_group_id
end

.listen_on(topic:) ⇒ Object 



29
30
31
32
33
34
 
# File 'lib/messaging/base_handler.rb', line 29

def listen_on(topic:)
  topics = Array(topic).map(&:to_s)
  Messaging.routes.consumer(name, group_id: group_id) do |c|
    topics.each { |t| c.on(->(m) { m.topic == t }, call: self) }
  end
end

.only_messages(messages = nil) ⇒ Object Also known as: only_message 



8
9
10
11
 
# File 'lib/messaging/base_handler.rb', line 8

def only_messages(messages = nil)
  @only_messages = Array(messages) if messages
  @only_messages || []
end

Instance Method Details

#on_message(message, _metadata) ⇒ Object 



43
 
# File 'lib/messaging/base_handler.rb', line 43

def on_message(message, _metadata); end